UpdateSnowflakeStream 2025.10.2.19¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
描述¶
通过创建、删除或替换 Snowflake 流来管理它们，操作基于配置的操作类型。Snowflake 中的流捕获表的数据变化，可用于跟踪一段时间内的 DML 变更。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
连接池 |
用于连接到 Snowflake 的连接池 |
对象标识符解析 |
控制在 Snowflake 中源对象标识符（架构、表、列）的存储和查询方式。此设置决定您在 SQL 查询中是否需要使用双引号。 |
架构名称 |
包含流和/或源表的架构的名称 |
Source Table Name |
流源表的名称 |
Stream Creation Parameters |
要包含在 CREATE STREAM 语句中的其他参数。例如，'APPEND_ONLY=TRUE SHOW_INITIAL_ROWS=TRUE' |
Stream Name |
要创建、删除或替换的流的名称 |
Update Type |
要执行的流操作的类型 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果无法完成流操作，则传入的 FlowFile 将路由到此关系 |
未找到对象 |
如果指定的流或源表不存在，则传入的 FlowFile 将路由到此关系。 |
success |
成功完成流操作后，传入 FlowFile 的内容将路由到此关系 |