PickTablesForReplication 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Akzeptiert eine Liste vollqualifizierter Tabellennamen und stellt fest, ob eine Tabelle: - neu ist (wird nicht repliziert, wurde aber in der Quelle hinzugefügt) - vorhanden ist (wird repliziert und ist in der Quelle vorhanden) - veraltet ist (wird repliziert, aber existiert nicht mehr in der Quelle). Die Konfiguration wird als FlowFile-Attribut übergeben. Der Prozessor generiert ein separates FlowFile für jede Quelltabelle.

Tags¶

snowflake, state, table

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Table State Service	Ein Dienst, der die aktuell replizierten Tabellen und deren Status enthält

Beziehungen¶

Name	Beschreibung
existing	FlowFile mit qualifiziertem Tabellennamen, der bereits repliziert wird
failure	Wenn ein FlowFile-Attribut nicht gelesen werden kann oder falsch ist, wird es an diese Beziehung weitergeleitet.
new	FlowFile mit qualifiziertem Tabellennamen, der nicht repliziert wurde
stale	FlowFile mit dem qualifizierten Tabellennamen, der früher repliziert wurde, aber nicht mehr repliziert wird, entweder weil er aus der Quelldatenbank entfernt oder durch einen Parameter ausgeschlossen wurde.

Schreibt Attribute¶

Name	Beschreibung
source.schema.name	Name des Schemas der Tabelle, aus der ein Ereignis stammt
source.table.name	Name der Tabelle, aus der ein Ereignis stammt