MergeSnowflakeJournalTable 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Triggers a merge operation on changes from journal table to a destination table in Snowflake. The merge operation is performed asynchronously and the processor polls the result of the operation. If the query is still in progress the FlowFile will be penalized.

Tags¶

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Destination Database Name	Der Name der Snowflake-Datenbank, in die die Daten aufgenommen werden
Merge Query Retry Count	Gibt an, wie oft die Abfrage wiederholt werden soll, wenn sie fehlschlägt.
Auflösung des Objektbezeichners	Steuert, wie die Bezeichner der Quellobjekte (Schemas, Tabellen, Spalten) in Snowflake gespeichert und abgefragt werden. Diese Einstellung bestimmt, ob Sie in Ihren SQL-Abfragen doppelte Anführungszeichen verwenden müssen. Die Option „Case-Sensitive“ ist das Standardverhalten in der Produktion – „Case-Insensitive“ gilt vorerst als Vorschau.
Placeholder Value	Der Wert des Nutzlast-Platzhalters, nach dem in einem MERGE gesucht werden soll. Dies wird in den Datentyp der Zielspalte konvertiert.
Snowflake Connection Pool	Der Controller-Dienst, der verwendet wird, um eine Verbindung zur Snowflake-Datenbank herzustellen, um die Zusammenführungsoperation durchzuführen.
Unchanged Value Strategy	Legt fest, wie die MERGE-Abfrage unveränderte Werte in Journalspalten behandeln soll. Standardmäßig werden vollständige Werte erwartet.

Beziehungen¶

Name	Beschreibung
ddl	Auszuführende DDL.
deleted during compaction	FlowFile wurde während der Komprimierung basierend auf dem Tabellennamen und der Generierung gelöscht.
failure	Fehler bei der Abfrageausführung.
failure retry	Fehler bei der wiederholten Abfrageausführung.
poll query result	Geplante asynchrone Abfrageausführung.
success	Erfolgreiche Ausführung der Abfrage.
unknown file type	Unbekannter Dateityp.

Schreibt Attribute¶

Name	Beschreibung
merge.query.id	Die ID der Abfrage, die verwendet wird, um die Journaltabelle mit der Zieltabelle zusammenzuführen.