ray.data.Datasource.write

Datasource.write(blocks: Iterable[Union[pyarrow.Table, pandas.DataFrame]], **write_args) → Any

Write blocks out to the datasource. This is used by a single write task.

Parameters

• blocks – List of data blocks.

• write_args – Additional kwargs to pass to the datasource impl.

Returns

The output of the write task.