ray.data.Datasink.write#
- Datasink.write(blocks: Iterable[pyarrow.Table | pandas.DataFrame], ctx: TaskContext) Any[源代码]#
写入块。这由一个单独的写入任务使用。
- 参数:
blocks – 数据块生成器。
ctx –
TaskContext用于写任务。
- 返回:
用户定义的输出。可以是任何内容，返回值会传递给
on_write_complete()。
写入块。这由一个单独的写入任务使用。
blocks – 数据块生成器。
ctx – TaskContext 用于写任务。
用户定义的输出。可以是任何内容，返回值会传递给 on_write_complete()。