code: def read_parquet(
      root: str,
      parallelism: int = -1,
      use_threads: bool = False,
      filter=None,
      columns=None,
  ) -> Dataset:
      return ray.data.read_parquet(
          paths=root,
          parallelism=parallelism,
          use_threads=use_threads,
          filter=filter,
          columns=columns,
      ).materialize()
  
file_path: ray/release/nightly_tests/dataset/read_parquet_benchmark.py
imports: import ray
  from ray.data.dataset import Dataset
  from benchmark import Benchmark
  from parquet_data_generator import generate_data
  import shutil
  import tempfile
label_desc: Use image node_id 1 for calling a global function with example usage: read_parquet(root, parallelism, use_threads, filter, columns) and returns: ray