ray.data.Datasink.write

Datasink.write(blocks: Iterable[pyarrow.Table | pandas.DataFrame], ctx: TaskContext) → None

Write blocks. This is used by a single write task.

Parameters:

• blocks – Generator of data blocks.

• ctx – TaskContext for the write task.