diff --git a/modin/engines/ray/pandas_on_ray/io.py b/modin/engines/ray/pandas_on_ray/io.py
index <HASH>..<HASH> 100644
--- a/modin/engines/ray/pandas_on_ray/io.py
+++ b/modin/engines/ray/pandas_on_ray/io.py
@@ -51,7 +51,8 @@ def _read_parquet_columns(path, columns, num_splits, kwargs):  # pragma: no cove
     """
     import pyarrow.parquet as pq
 
-    df = pq.read_pandas(path, columns=columns, **kwargs).to_pandas()
+    df = pq.ParquetDataset(path, **kwargs).read(columns=columns).to_pandas()
+
     # Append the length of the index here to build it externally
     return _split_result_for_readers(0, num_splits, df) + [len(df.index)]
Replace read_pandas with ParquetDataset to support predicate pushdown (#<I>)

* Replace read_pandas with ParquetDataset to support predicate pushdown on parquet



* reformatted as per black