EnrichCdcStream 2025.10.2.19¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
描述¶
Enriches incoming FlowFiles that come from CaptureChangePostgreSQL, etc. with information pertaining to which Journal Table to write to and relevant schema information. This Processor manages the schema versions for each table being processed in order to ensure that the correct Journal Table is used for each FlowFile.
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
CDC 架构注册表 |
指定用于管理 CDC 数据架构的 CDC 架构注册表 |
记录读取器 |
指定用于读取传入数据的记录读取器 |
记录写入器 |
指定用于写入传出数据的记录写入器 |
表状态服务 |
保存复制表的状态 |
状态管理¶
范围 |
描述 |
|---|---|
CLUSTER |
跟踪每个正在处理的表所对应的当前日志表版本。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果某个 FlowFile 无法读取，则将路由到此关系。 |
schema update |
如果需要任何架构更新来处理传入的记录，FlowFile 则将路由到此关系。FlowFile 将包括架构信息，以表明需要进行哪些更改。 |
skipped ddl event |
此关系将用于处理那些不会导致目标表架构变化的 DDL / 架构更改事件的关系。 |
success |
要插入到 Snowflake 表中的行将路由到此关系。 |
table not in state |
当 FlowFile 引用的表在复制表的状态中不存在（可能是因为该表已从复制中移除）时使用。 |
写入属性¶
名称 |
描述 |
|---|---|
table.schema.generation |
用于增量处理的日志表索引。 |
table.schema.initial |
标记日志表的初始生成。 |
destination.table.schema |
目标表的更新架构。此属性仅为 DDL 事件编写。 |