ray.data.Datasink.on_write_start# Datasink.on_write_start() → None[源代码]# 写作业开始时的回调。 使用此方法为写任务执行设置。例如,在S3中创建一个暂存桶。