在BigQueryIO.Write成功完成后调用方法

Is there a way to run some code after BigQueryIO.Write transform has successfully finished? i.e something similar to finishBundle method.

有没有办法在BigQueryIO.Write转换成功完成后运行一些代码？类似于finishBundle方法。

I am aware of DataflowPipelineJob.waitToFinish but that requires the application that started the pipeline to be running.

我知道DataflowPipelineJob.waitToFinish，但这需要启动管道的应用程序运行。

1 个解决方案

#1

There is not currently a way to execute something after a BigQueryIO.Write transform completes.

在BigQueryIO.Write转换完成后，目前没有办法执行某些操作。