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>] }

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

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.