WaitForTableState 2025.10.2.19

Bundle

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

Beschreibung

Blockiert eingehende FlowFiles, bis der entsprechende Tabellenstatus nicht mehr mit dem akzeptierten Status übereinstimmt. Gesperrte FlowFiles bleiben in der Upstream-Warteschlange. Wenn sich die Tabelle im beendeten Zustand befindet oder die Tabelle aus dem Zustand entfernt wird, dann werden alle FlowFiles an die ‚Failure‘-Beziehung weitergeleitet.

Tags

cdc, event, jdbc, mysql, postgresql, sql

Eingabeanforderung

REQUIRED

Unterstützt sensible dynamische Eigenschaften

false

Eigenschaften

Eigenschaft

Beschreibung

Zustand „Akzeptiert“

Blockiert FlowFilesfür einen bestimmten SourceTableFQN, bis der entsprechende Status dem akzeptierten Status entspricht.

Table State Service

Verwaltet den Status der einzelnen replizierten Tabellen

Beziehungen

Name

Beschreibung

failure

FlowFiles für Tabellen in Endzuständen werden an diese Beziehung weitergeleitet.

success

FlowFiles, die eine bestimmte Bedingung erfüllen, werden an diese Beziehung weitergeleitet.