UpdateSnowflakeDatabase 2025.10.2.19¶

バンドル¶

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

説明¶

Updates the definition of a Snowflake table based on the schema provided in the incoming FlowFile. The schema is expected to be in JSON with the following format, regardless of whether it is provided via FlowFile content or specified as a property: { "columns": [ { "name": "<column name>", "type": "<column type>", "nullable": <true/false>, "precision": <precision, only for numeric type>, "scale": <scale, only for numeric type> }, ... ], "primaryKeys": ["<name of first primary key column>", "<name of second primary key column>", ...] }

タグ¶

入力要件¶

REQUIRED

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

false

プロパティ¶

プロパティ	説明
列ストラテジーの追加	入力スキーマが既存のテーブルに存在しない列を持つ場合に使用するストラテジー。
Not Null ストラテジーの追加	入力スキーマに、既存のテーブルには存在しないnot-null制約がある場合に使用するストラテジーです。
Alter Column Type Strategy	The strategy to use when the existing table has a column with a different type than the incoming schema.
列名の変換	スキーマで定義された列名に適用できるオプションの変換。この変換は、テーブルの既存の列と比較される前に、列名に適用されます。このプロパティは、属性に加えて、式言語を介して以下の変数をリファレンスできます。`column.name`、 `column.type`、 `column.nullable`、 `column.precision`、 `column.scale`、 `column.primaryKey`。
列の削除ストラテジー	既存のテーブルに、入力スキーマに存在しない列がある場合に使用するストラテジー。
接続プール	Snowflakeへの接続に使用する接続プール。
ストリームを作成	テーブルにSnowflakeストリームを作成するかどうか
作成パラメーター	CREATE TABLE ステートメントに含める追加パラメーター。例えば、 'CLUSTER BY (列名)' です。
目的スキーマ	必要なスキーマ/テーブル定義
列ストラテジーの削除	既存のテーブルに、入力スキーマに存在しない列がある場合に使用するストラテジー。
Not Nullストラテジーの削除	既存のテーブルにnot-null制約があり、それが入力スキーマに存在しない場合に使用するストラテジーです。
デフォルト値を含める	Whether or not to include DEFAULT values in CREATE TABLE or ALTER TABLE ADD COLUMN statements
Nullでない制約を含む	CREATE TABLE または ALTER TABLE ADD COLUMN ステートメントに NOT NULL 制約を含めるかどうか。
プライマリキー制約を含む	作成ステートメントにプライマリキー制約を含めるかどうか
最大バッチサイズ	指定されたテーブルの1回の実行で処理できる FlowFiles の最大数。
プライマリキーストラテジーの変更	入力スキーマが既存のプライマリキーと異なるプライマリキーを持つ場合に使用するストラテジー。プライマリキーを変更するには、既存のキーを削除し、新しいキーを追加する必要があります。
Record Reader	目的のスキーマを取得するために使用するRecord Reader
列名サフィックスの削除	The suffix to append to a column that was removed. For example, to rename column 'foo' to 'foo__deleted', the property can be set to `__deleted`
スキーマ名	更新するスキーマの名前
ストリーム作成パラメーター	CREATE STREAM ステートメントに含める追加パラメーター。例えば、 'APPEND_ONLY=TRUE' です。
ストリーム名	ストリームの名前
テーブル・メタデータ・キャッシュの有効期限	キャッシュエントリが削除されるまでの時間（秒）。
テーブル名	ストリームを更新または作成するテーブルの名前。
テーブルスキーマストラテジー	必要なスキーマ/テーブル定義の取得方法を指定します。
テーブルストリーム作成パラメーター	CREATE STREAM ステートメントに含めるパラメーター。例えば、 'APPEND_ONLY=TRUE' です。ストリームは、テーブルをソースとして作成されます。
テーブルストリーム名	テーブルとともに作成されるストリームの名前。ストリーム・ソースは作成されたテーブルになります。
更新タイプ	実行するアップデートのタイプ
テーブル・メタデータ・キャッシュの使用	テーブルのメタデータをSnowflakeから直接読み込むのではなく、キャッシュするかどうか。[テーブルが存在しない場合はテーブルを作成、テーブルを変更] に適用されます。

リレーションシップ¶

名前	説明
failure	テーブルを更新できない場合、 FlowFile はこのリレーションシップにルーティングされます。
success	FlowFile は、テーブルが正常に更新された後、このリレーションシップにルーティングされます。

属性の書き込み¶

名前	説明
schema.hash	すべての更新が完了した後の、最終的なテーブルスキーマの SHA-256ハッシュ。変更検出とキャッシュの目的で使用できます。