PickTablesForReplication 2025.5.31.15¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
描述¶
接受完全限定表名的列表，并确定以下表：- 为新表（未复制，但已添加到源中）- 已存在（已复制，并且存在于源中）- 已过时（已复制，但在源中已不存在）配置作为 FlowFile 属性传递。处理器为每个源表生成一个单独的 FlowFile。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
表状态服务 |
包含当前复制的表及其状态的服务 |
关系¶
名称 |
描述 |
|---|---|
existing |
具有已复制的限定表名的 FlowFile |
failure |
如果某个 FlowFile 属性无法读取或不正确，则会将路由到此关系。 |
new |
具有未复制的限定表名的 FlowFile |
stale |
具有曾被复制但现已不再复制的限定表明的 FlowFile，原因可能是因为它已从源数据库中移除，也可能是因为已被参数排除 |
写入属性¶
名称 |
描述 |
|---|---|
source.schema.name |
事件来源表的架构名称 |
source.table.name |
事件来源表的名称 |