PickTablesForReplication 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Description¶
Accepte une liste de noms de tables entièrement qualifiés et détermine si une table : - est nouvelle (n’est pas répliquée, mais a été ajoutée dans la source) - est existante (est répliquée et existe dans la source) - est périmée (est répliquée mais n’existe plus dans la source) La configuration est transmise en tant qu’attribut de FlowFile. Le processeur génère un FlowFile distinct pour chaque table source.
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 |