MergeSnowflakeJournalTable 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Beschreibung¶
Löst eine Operation zur Zusammenführung für Änderungen von der Journaltabelle zu einer Zieltabelle in Snowflake aus. Der Operation zur Zusammenführung wird asynchron durchgeführt, und der Prozessor fragt das Ergebnis der Operation ab. Wenn die Abfrage noch läuft, wird das FlowFile zurückgestellt.
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. |
Record Reader |
Der Record Reader, der zum Lesen der Eingabe verwendet wird |
Snowflake Connection Pool |
Der Controller-Dienst, der verwendet wird, um eine Verbindung zur Snowflake-Datenbank herzustellen, um die Zusammenführungsoperation durchzuführen. |
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. |