UpdateSnowflakeIcebergDatabase 2025.10.2.19¶

バンドル¶

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

説明¶

Snowflake Icebergテーブルの定義を更新します。ターゲットスキーマは、 RecordReader から推論するか、以下の形式を使用して明示的に定義できます。 { "columns": [ { "name": "<column name>", "type": "<iceberg data type>" }, ... ] } この場合、 <iceberg data type> は次のいずれかになります。 - プリミティブiceberg型 ("string", "int", "boolean",...) - 任意の精度とスケールの10進数 ("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>] }

タグ¶

iceberg

入力要件¶

REQUIRED

機密動的プロパティをサポート¶

false

プロパティ¶

プロパティ	説明
列ストラテジーの追加	入力スキーマが既存のテーブルに存在しない列を持つ場合に使用するストラテジー。
列ストラテジーの変更	列のデータ型が既存のテーブルと異なる場合に使用するスキーマ。
列型の変更ストラテジー	既存のテーブルに、受信スキーマとは異なる型の列がある場合に使用するストラテジー。
接続プール	Snowflakeへの接続に使用する接続プール。
目的スキーマ	必要なスキーマ/テーブル定義
列ストラテジーの削除	既存のテーブルに、入力スキーマに存在しない列がある場合に使用するストラテジー。
最大バッチサイズ	指定されたテーブルの1回の実行で処理できる FlowFiles の最大数。
Record Reader	目的のスキーマを取得するために使用するRecord Reader
スキーマ名	更新するスキーマの名前
テーブル・メタデータ・キャッシュの有効期限	キャッシュエントリが削除されるまでの時間（秒）。
テーブル名	更新するテーブルの名前
テーブルスキーマストラテジー	必要なスキーマ/テーブル定義の取得方法を指定します。
テーブル・メタデータ・キャッシュの使用	テーブルのメタデータをSnowflakeから直接読み込む代わりにキャッシュするかどうか

リレーションシップ¶

名前	説明
failure	テーブルを更新できない場合、 FlowFile はこのリレーションシップにルーティングされます。
違法改造	更新が失敗するように構成された変更を必要とする場合、受信 FlowFile は、このリレーションシップにルーティングされます。
success	FlowFile は、テーブルが正常に更新された後、このリレーションシップにルーティングされます。
テーブルが見つかりません	指定されたテーブルが存在しない場合、着信 FlowFile はこのリレーションシップにルーティングされます。

属性の書き込み¶

名前	説明
schema.hash	すべての更新が完了した後の、最終的なテーブルスキーマの16進数エンコード SHA-256ハッシュ。