UpdateSnowflakeIcebergDatabase 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
Beschreibung¶
Aktualisiert die Definition einer Snowflake Iceberg-Tabelle. Ein Zielschema kann aus einem RecordReader abgeleitet oder explizit definiert werden, indem das folgende Format verwendet wird:{ „columns“: [ { „name“: „<column name>“, „type“: „<iceberg data type>“ }, … ]}wobei <Iceberg-Datentyp> einer der folgenden sein kann:- primitiver Iceberg-Typ („string“, „int“, „boolean“,…)- dezimal mit gegebener Genauigkeit und Skala („decimal(P,S)“)- {„type“: „list“, „element“: <iceberg data type>}- {„type“: „map“, „key“: <iceberg data type>, „value“: <iceberg data type>}- {„type“: „struct“, „fields“:[<list of struct fields>] }
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
---|---|
Strategie zum Hinzufügen von Spalten |
Die Strategie, die verwendet wird, wenn das eingehende Schema eine Spalte enthält, die in der vorhandenen Tabelle nicht vorhanden ist |
Alter Column Strategy |
Die Strategie, die verwendet werden soll, wenn eine Spalte im eingehenden Schema einen anderen Datentyp hat als in der vorhandenen Tabelle |
Connection Pool |
Der Verbindungspool, der für die Verbindung mit Snowflake verwendet wird |
Gewünschtes Schema |
Die gewünschte Schema-/Tabellendefinition |
Strategie für das Löschen von Spalten |
Die Strategie, die verwendet werden soll, wenn die vorhandene Tabelle eine Spalte hat, die im eingehenden Schema nicht vorhanden ist |
Max Batch Size |
Die maximale Anzahl von FlowFiles, die in einer einzigen Ausführung für eine bestimmte Tabelle verarbeitet werden kann. |
Record Reader |
Record Reader zum Abrufen des gewünschten Schemas |
Schema Name |
Der Name des zu aktualisierenden Schemas |
Table Metadata Cache Expiration Time |
Die Zeit in Sekunden, nach der der Cache-Eintrag entfernt werden soll |
Tabellenname |
Der Name der zu aktualisierenden Tabelle |
Tabellenschemastrategie |
Gibt an, wie Sie die gewünschte Schema-/Tabellendefinition erhalten |
Use Table Metadata Cache |
Ob die Metadaten der Tabelle zwischengespeichert werden sollen, anstatt sie direkt aus Snowflake zu lesen |
Beziehungen¶
Name |
Beschreibung |
---|---|
failure |
Das eingehende FlowFile wird an diese Beziehung weitergeleitet, wenn die Tabelle nicht aktualisiert werden kann. |
illegal alteration |
Das eingehende FlowFile wird an diese Beziehung weitergeleitet, wenn die Aktualisierung eine Änderung erfordert, die so konfiguriert ist, dass sie fehlschlägt. |
success |
Das eingehende FlowFile wird an diese Beziehung weitergeleitet, nachdem die Tabelle erfolgreich aktualisiert wurde. |
table not found |
Das eingehende FlowFile wird an diese Beziehung weitergeleitet, wenn die angegebene Tabelle nicht existiert. |