UpdateSnowflakeIcebergDatabase 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Updates the definition of a Snowflake Iceberg table. A target schema can be inferred from a RecordReader or defined explicitly using the format below: { „columns“: [ { „name“: „<column name>“, „type“: „<iceberg data type>“ }, … ] } where <iceberg data type> can be one of: - primitive iceberg type („string“, „int“, „boolean“,…) - decimal with given precision and scale („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
Alter Column Type Strategy	The strategy to use when the existing table has a column with a different type than the incoming 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.