写入表后的Apache Beam Pipeline查询表

写入表后的Apache Beam Pipeline查询表

Beam当前不支持用例“在BigQuery写入完成后执行某些 *** 作”。唯一的解决方法是运行单独的管道：让您的主程序为：运行写入BigQuery的管道；等待管道完成；运行另一个从BigQuery读取的管道。

这是一个非常常用的功能，我们开始设计这种支持（更广泛地说，是在升级各种IO写入以支持它们之后的排序 *** 作），但是我不知道何时完成。