Skip to content

Commit 77b4ecb

Browse files
committed
Add ValueError for metadata in FileSystem.read_parquet
1 parent 33bf492 commit 77b4ecb

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

‎python/pyarrow/filesystem.py‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -223,8 +223,12 @@ def read_parquet(self, path, columns=None, metadata=None, schema=None,
223223
table : pyarrow.Table
224224
"""
225225
from pyarrow.parquet import ParquetDataset
226-
dataset = ParquetDataset(path, schema=schema, metadata=metadata,
227-
filesystem=self)
226+
227+
if metadata is not None:
228+
raise ValueError(
229+
"Keyword 'metadata' is not supported with the Dataset API")
230+
231+
dataset = ParquetDataset(path, schema=schema, filesystem=self)
228232
return dataset.read(columns=columns, use_threads=use_threads,
229233
use_pandas_metadata=use_pandas_metadata)
230234

0 commit comments

Comments
 (0)