PickTablesForReplication 2025.10.2.19¶
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.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Service d’état de table |
Un service contenant les tables actuellement répliquées et leur état |
Relations¶
Nom |
Description |
|---|---|
existing |
FlowFile avec un nom de table qualifié qui est déjà répliqué |
failure |
Si un attribut FlowFile ne peut pas être lu ou est incorrect, il sera routé vers cette relation. |
new |
FlowFile avec un nom de table qualifié qui n’est pas répliqué |
stale |
FlowFile avec un nom de table qualifié qui était répliqué mais ne l’est plus, soit parce qu’il a été supprimé de la base de données source, soit parce qu’il a été exclu par le paramètre |
Écrit les attributs¶
Nom |
Description |
|---|---|
source.schema.name |
Nom du schéma de la table d’où provient un événement |
source.table.name |
Nom de la table d’où provient un événement |