带有动态查询的 beamsql

Question

我们有一个 Apache Beam 管道，需要 运行 多个 BeamSql 查询。 这些查询在管道构建时是未知的，但在管道 运行ning 时就会知道。查询将定期更新。 BeamSql 可以吗？我们正在使用 Google 数据流 运行ner.

Answer 1

恐怕这对于 Beam SQL 是不可能的。查询在构造时被转换为管道结构。

那么，您是否收到 SQL 语句作为管道的输入？一种可能性是从您的管道中启动 "sub" 个管道。