在PDone之后执行处理

Question

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

Answer 1

在IO.write（）之后，IO中有一种方法可以返回PTransform。例如TextIO.write（）。withOutputFilenames（）。但它是IO特定的，所以不是每个IO都有这样的API。

PDone不能用于进一步处理。