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.

Tags¶

snowflake, state, 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