PickTablesForReplication 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Description¶
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.
Input Requirement¶
REQUIRED
Supports Sensitive Dynamic Properties¶
false
Properties¶
Property |
Description |
|---|---|
Table State Service |
A service containing currently replicated tables and their states |
Relationships¶
Name |
Description |
|---|---|
existing |
FlowFile with qualified table name that is already being replicated |
failure |
If a FlowFile attribute cannot be read or is incorrect, it will be routed to this Relationship. |
new |
FlowFile with qualified table name that was is not replicated |
stale |
FlowFile with qualified table name that used to be replicated but no longer is, either because it was removed from source database or excluded by parameter |
Writes attributes¶
Name |
Description |
|---|---|
source.schema.name |
Name of the schema of the table from which an event originated |
source.table.name |
Name of the table from which an event originated |