WaitForTableState 2025.5.31.15

Bundle

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

Beschreibung

Blockiert eingehende FlowFiles solange, bis der entsprechende Tabellenstatus nicht gleich dem akzeptierten Status ist. Blockierte FlowFiles bleiben in der Upstream-Warteschlange. Wenn sich die Tabelle in einem beendeten Zustand befindet oder aus dem Zustand entfernt wird, werden alle FlowFiles an die Beziehung „failure“ 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.