ray.data.Datasink.on_write_start#

Datasink.on_write_start() None[源代码]#

写作业开始时的回调。

使用此方法为写任务执行设置。例如,在S3中创建一个暂存桶。