WaitForTableState 2025.10.9.21

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.

Tags

cdc, event, jdbc, mysql, postgresql, sql

Input Requirement

REQUIRED

Supports Sensitive Dynamic Properties

false

Properties

PropertyDescription
Accepted StateBlocks FlowFiles for a given SourceTableFQN until corresponding state is equal to the Accepted State
Table State ServiceManages the state of each replicated table

Relationships

NameDescription
failureFlowFiles for tables in terminal states will be routed to this relationship
successFlowFiles fulfilling a given condition will be routed to this relationship