ray.data.DatasetPipeline.write_datasource#

DatasetPipeline.write_datasource(datasource: ray.data.datasource.datasource.Datasource[ray.data.block.T], *, ray_remote_args: Optional[Dict[str, Any]] = None, **write_args) → None[source]#

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