Выполнение обработки после PDone

Question

Есть ли способ использовать результат из приемника, то есть PDone, для дальнейшей обработки, такой как отправка сообщения в Pub / Sub только тогда, когда данные полностью записаны в GCS или все строки записаны в BigQuery?

Answer 1

В IO есть способ вернуть PTransform после IO.write ().Например, TextIO.write (). WithOutputFilenames ().Но это специфично для IO, и поэтому не у каждого IO есть такой API.

PDone не может быть использован для дальнейшей обработки.