UpdateSnowflakeIcebergDatabase 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Aktualisiert die Definition einer Snowflake Iceberg-Tabelle. Ein Zielschema kann aus einem RecordReader abgeleitet werden oder explizit unter Verwendung des folgenden Formats definiert werden: { „columns“: [ { „name“: „<column name>“, „type“: „<iceberg data type>“ }, … ] } wobei <iceberg data type> einer der folgenden sein kann: - primitiver Iceberg-Typ („string“, „int“, „boolean“,…) - Dezimalzahl mit angegebener Genauigkeit und Skalierung („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>] }

Tags¶

iceberg

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
Strategie zum Ändern des Spaltentyps	Die Strategie, die verwendet werden soll, wenn die bestehende Tabelle eine Spalte mit einem anderen Typ hat als das eingehende Schema.
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.

Schreibt Attribute¶

Name	Beschreibung
schema.hash	Ein hexadezimal-codierter SHA-256 Hash des endgültigen Tabellenschemas, nachdem alle Aktualisierungen abgeschlossen wurden.