执行 PDone 后的处理
Performing processing after PDone
是否有任何方法可以利用接收器的结果,即 PDone
进行进一步处理,例如仅当数据已完全写入 GCS 或所有行都已完成时才向 Pub/Sub 发送消息已写入 BigQuery?
在 IOs 中有一种方法可以在 IO.write() 之后实现 return PTransform。例如 TextIO.write().withOutputFilenames()。但它是特定于 IO 的,因此并非每个 IO 都有这样的 API。
PDone 不能用于进一步处理。
是否有任何方法可以利用接收器的结果,即 PDone
进行进一步处理,例如仅当数据已完全写入 GCS 或所有行都已完成时才向 Pub/Sub 发送消息已写入 BigQuery?
在 IOs 中有一种方法可以在 IO.write() 之后实现 return PTransform。例如 TextIO.write().withOutputFilenames()。但它是特定于 IO 的,因此并非每个 IO 都有这样的 API。
PDone 不能用于进一步处理。