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.
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. |