google-cloud-dataflow - 在 PDone 之后执行处理

Question

有没有办法利用接收器的结果，即PDone进行进一步处理，例如仅在数据已完全写入 GCS 或所有行已写入 BigQuery 时才向 Pub/Sub 发送消息？

标签： google-cloud-dataflowapache-beamdataflowapache-beam-io

Answer 1

IO 中有一种方法可以在 IO.write() 之后返回 PTransform。例如 TextIO.write().withOutputFilenames()。但它是特定于 IO 的，因此并非每个 IO 都有这样的 API。

PDone 不能用于进一步处理。