MergeSnowflakeJournalTable 2025.10.2.19¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
描述¶
Triggers a merge operation on changes from journal table to a destination table in Snowflake. The merge operation is performed asynchronously and the processor polls the result of the operation. If the query is still in progress the FlowFile will be penalized.
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
目标数据库名称 |
要将数据引入到的 Snowflake 数据库的名称。 |
合并查询重试次数 |
表示如果合并查询失败，应重试多少次。 |
对象标识符解析 |
控制在 Snowflake 中源对象标识符（架构、表、列）的存储和查询方式。此设置决定您在 SQL 查询中是否需要使用双引号。“区分大小写”选项是默认的生产行为，“不区分大小写”目前被视为预览功能。 |
占位符值 |
在 MERGE 中要查找的有效负载占位符的值。这将转换为目标列的数据类型。 |
Snowflake 连接池 |
用于获取与 Snowflake 数据库的连接，以执行合并操作的控制器服务。 |
未更改值策略 |
确定 MERGE 查询在日志列中如何处理未更改的值。默认情况下，它需要完整值。 |
关系¶
名称 |
描述 |
|---|---|
ddl |
要执行的 DDL。 |
deleted during compaction |
在压缩期间根据表名称和生成删除的 FlowFile。 |
failure |
查询执行失败。 |
failure retry |
重试失败查询执行。 |
poll query result |
计划的异步查询执行。 |
success |
查询执行成功。 |
unknown file type |
未知的文件类型。 |
写入属性¶
名称 |
描述 |
|---|---|
merge.query.id |
用于将日记账表合并到目标表的查询的 ID。 |