Read parquet files using standard Ray.
(self, path: Union[str, List[str]], **kwargs)
| 212 | """Wrapper for Ray Native operations.""" |
| 213 | |
| 214 | def read_parquet(self, path: Union[str, List[str]], **kwargs) -> Any: |
| 215 | """Read parquet files using standard Ray.""" |
| 216 | return ray.data.read_parquet(path, **kwargs) |
| 217 | |
| 218 | def read_csv(self, path: Union[str, List[str]], **kwargs) -> Any: |
| 219 | """Read CSV files using standard Ray.""" |
no outgoing calls