ray.data.Datasink.on_write_complete

Datasink.on_write_complete(write_results: List[Any]) → None

写作业完成时的回调。

这可以用于“提交”一个写入输出。在 write_datasink() 返回给用户之前，此方法必须成功。如果此方法失败，则调用 on_write_failed()。

参数:

write_results – 每个 write() 任务返回的对象。