WaitForTableState 2025.10.2.19

Bundle

com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar

Description

Blocks incoming FlowFiles until the corresponding table state is not equal to accepted state. Blocked FlowFiles stay in the upstream queue. When table is in terminated state or table is removed from the state then all FlowFiles are routed to the “failure” relationship.

Balises

cdc, event, jdbc, mysql, postgresql, sql

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