class_docstr: Minimal Parquet datasource, for reading and writing Parquet files.
code: def _read_stream(self, f: "pyarrow.NativeFile", path: str):
      import pyarrow.parquet as pq
  
      use_threads = self.read_table_args.pop("use_threads", False)
      yield pq.read_table(
          f, use_threads=use_threads, **self.read_table_args
      )
  
file_path: ray/python/ray/data/datasource/parquet_base_datasource.py
imports: import logging
  from typing import TYPE_CHECKING, Any, Dict, List, Optional, Union
  from ray.data.datasource.file_based_datasource import FileBasedDatasource
  from ray.util.annotations import PublicAPI
label_desc: Use image node_id 3 for calling the ParquetBaseDatasource obj's underlying member method code with example usage: obj._read_stream(f, path) without return types