Skip to content

Commit 896abb2

Browse files
simplify read_table (use ParquetDataset directly)
1 parent 2ea7350 commit 896abb2

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

python/pyarrow/parquet.py

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1192,12 +1192,9 @@ def read_table(source, columns=None, use_threads=True, metadata=None,
11921192
use_pandas_metadata=False, memory_map=True,
11931193
filesystem=None):
11941194
if _is_path_like(source):
1195-
fs, path = _get_filesystem_and_path(filesystem, source)
1196-
return fs.read_parquet(path, columns=columns,
1197-
use_threads=use_threads, metadata=metadata,
1198-
use_pandas_metadata=use_pandas_metadata)
1199-
1200-
pf = ParquetFile(source, metadata=metadata)
1195+
pf = ParquetDataset(source, metadata=metadata, filesystem=filesystem)
1196+
else:
1197+
pf = ParquetFile(source, metadata=metadata)
12011198
return pf.read(columns=columns, use_threads=use_threads,
12021199
use_pandas_metadata=use_pandas_metadata)
12031200

0 commit comments

Comments
 (0)