MergeSnowflakeJournalTable 2025.5.31.15¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
描述¶
在 Snowflake 中，针对从日记表到目标表的变更触发合并操作。合并操作异步执行，处理器轮询操作结果。如果查询仍在进行中，则 FlowFile 将受到惩罚。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
目标数据库名称 |
要将数据引入到的 Snowflake 数据库的名称。 |
合并查询重试次数 |
表示如果合并查询失败，应重试多少次。 |
记录读取器 |
用于读取输入的记录读取器 |
Snowflake 连接池 |
用于获取与 Snowflake 数据库的连接，以执行合并操作的控制器服务。 |
关系¶
名称 |
描述 |
|---|---|
ddl |
要执行的 DDL。 |
deleted during compaction |
在压缩期间根据表名称和生成删除的 FlowFile。 |
failure |
查询执行失败。 |
failure retry |
重试失败查询执行。 |
poll query result |
计划的异步查询执行。 |
success |
查询执行成功。 |
unknown file type |
未知的文件类型。 |
写入属性¶
名称 |
描述 |
|---|---|
merge.query.id |
用于将日记账表合并到目标表的查询的 ID。 |