PickTablesForReplication 2025.10.2.19¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Beschreibung¶
Accepts a list of fully qualified table names and determines if a table: - is new (is not replicated, but was added in the source) - is existing (is replicated and exists in the source) - is stale (is replicated but no longer exists in the source) Configuration is passed as a FlowFile attribute. Processor generates a separate FlowFile for each source 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 |