Beam SQL 扩展：SET 和 RESET 管道选项

Beam SQL 的 SET 和 RESET 语句允许用户通过 SQL shell 配置管道选项。这些与命令行中传递给其他 Beam 应用程序的管道选项相同，格式为 --<option>=<value>。

语法

SET option = value

SET 命令设置管道选项。

• option：管道选项的区分大小写的名称，指定为 标识符。
• value：管道选项的区分大小写的值，指定为 标识符。对于命令行中没有值的标志选项，使用 true。

RESET option

RESET 命令将管道选项重置为其默认值。

• option：管道选项的区分大小写的名称，指定为 标识符。

常用选项

• SET project = `my_gcp_project` ：将默认 GCP 项目设置为 my_gcp_project。
• SET runner = DataflowRunner：将管道设置为在 Dataflow 上运行。