ray.data.DatasetPipeline.write_json

DatasetPipeline.write_json(path: str, *, filesystem: Optional[pyarrow.fs.FileSystem] = None, try_create_dir: bool = True, arrow_open_stream_args: Optional[Dict[str, Any]] = None, block_path_provider: ray.data.datasource.file_based_datasource.BlockWritePathProvider = <ray.data.datasource.file_based_datasource.DefaultBlockWritePathProvider object>, pandas_json_args_fn: Callable[[], Dict[str, Any]] = <function DatasetPipeline.<lambda>>, ray_remote_args: Dict[str, Any] = None, **pandas_json_args) → None

Call Dataset.write_json on each output dataset of this pipeline.