PickTablesForReplication 2025.5.31.15¶

Bundle¶

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

Beschreibung¶

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

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