ray.data.Datasource.write#

Datasource.write(blocks: Iterable[pyarrow.Table | pandas.DataFrame], ctx: TaskContext, **write_args) Any[source]#

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

Parameters:
  • blocks – List of data blocks.

  • ctxTaskContext for the write task.

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

Returns:

The output of the write task.

Warning

DEPRECATED: This API is deprecated and may be removed in future Ray releases.