WaitForTableState 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Description¶
Bloque les FlowFiles en entrée jusqu’à ce que l’état de la table correspondante diffère de l’état accepté. Les FlowFiles bloqués restent dans la file d’attente en amont. Lorsque la table est en état d’arrêt ou qu’elle est retirée de l’état, tous les FlowFiles sont routés vers la relation “failure”.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Accepted State |
Bloque les FlowFiles pour un SourceTableFQN donné jusqu’à ce que l’état correspondant soit égal à l’état accepté |
Service d’état de table |
Gestion de l’état de chaque table répliquée |
Relations¶
Nom |
Description |
|---|---|
failure |
FlowFiles pour les tables dans les états terminaux seront routées vers cette relation |
success |
FlowFiles remplissant une condition donnée seront routées vers cette relation |