Beam当前不支持用例“在BigQuery写入完成后执行某些操作”。唯一的解决方法是运行单独的管道:让您的主程序为:运行写入BigQuery的管道;等待管道完成;运行另一个从BigQuery读取的管道。
这是一个非常常用的功能,我们开始设计这种支持(更广泛地说,是在升级各种IO写入以支持它们之后的排序操作),但是我不知道何时完成。

Beam当前不支持用例“在BigQuery写入完成后执行某些操作”。唯一的解决方法是运行单独的管道:让您的主程序为:运行写入BigQuery的管道;等待管道完成;运行另一个从BigQuery读取的管道。
这是一个非常常用的功能,我们开始设计这种支持(更广泛地说,是在升级各种IO写入以支持它们之后的排序操作),但是我不知道何时完成。