ray.data.Datasink

class ray.data.Datasink

基类：object

用于定义写相关逻辑的接口。

如果你想将数据写入非内置的内容，可以继承此类并调用 write_datasink()。

开发者API: 此API可能会在Ray的次要版本之间发生变化。

方法

__init__
get_name	返回此数据接收器的可读名称。
on_write_complete	写作业完成时的回调。
on_write_failed	写入作业失败时的回调。
on_write_start	写作业开始时的回调。
write	写块。

属性

num_rows_per_write	每次调用 write() 时传递的目标行数。
supports_distributed_writes	如果 False ，仅在驱动节点上启动写任务。