PickTablesForReplication 2025.10.2.19¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
描述¶
Accepts a list of fully qualified table names and determines if a table: - is new (is not replicated, but was added in the source) - is existing (is replicated and exists in the source) - is stale (is replicated but no longer exists in the source) Configuration is passed as a FlowFile attribute. Processor generates a separate FlowFile for each source table.
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
表状态服务 |
包含当前复制的表及其状态的服务 |
关系¶
名称 |
描述 |
|---|---|
existing |
具有已复制的限定表名的 FlowFile |
failure |
如果某个 FlowFile 属性无法读取或不正确，则会将路由到此关系。 |
new |
具有未复制的限定表名的 FlowFile |
stale |
具有曾被复制但现已不再复制的限定表明的 FlowFile，原因可能是因为它已从源数据库中移除，也可能是因为已被参数排除 |
写入属性¶
名称 |
描述 |
|---|---|
source.schema.name |
事件来源表的架构名称 |
source.table.name |
事件来源表的名称 |