MergeSnowflakeJournalTable 2025.10.2.19¶

バンドル¶

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

説明¶

Triggers a merge operation on changes from journal table to a destination table in Snowflake. The merge operation is performed asynchronously and the processor polls the result of the operation. If the query is still in progress the FlowFile will be penalized.

タグ¶

入力要件¶

REQUIRED

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

false

プロパティ¶

プロパティ	説明
宛先データベース名	データを取り込むSnowflakeデータベースの名前。
マージクエリの再試行回数	マージ・クエリが失敗した場合に何回再試行するかを示します。
オブジェクト識別子の解決	ソースオブジェクト識別子（スキーマ、テーブル、列）がSnowflakeにどのように格納され、クエリされるかを制御します。この設定により、 SQL クエリで二重引用符を使用する必要があるかどうかが決まります。「大文字と小文字を区別する」オプションはデフォルトの実稼働環境の動作であり、「大文字と小文字を区別しない」は現時点ではプレビューと見なされます。
プレースホルダー値	MERGE で探すペイロードプレースホルダーの値。これは変換先の列のデータ型に変換されます。
Snowflake 接続プール	Snowflakeデータベースへの接続を取得し、マージ処理を実行するために使用するController Service。
不変のバリュー戦略	MERGE クエリが仕訳帳列の未変更値をどのように処理するかを決定します。デフォルトでは、完全な値が期待されます。

リレーションシップ¶

名前	説明
ddl	実行する DDL
コンパクション中に削除された	テーブル名と世代に基づいてコンパクション中に削除された FlowFile。
failure	クエリ実行の失敗。
失敗リトライ	クエリ実行の失敗を再試行します。
クエリ結果のポーリング	スケジュールされた非同期クエリ実行。
success	クエリの実行の成功。
不明なファイルタイプ	不明なファイルタイプ。

属性の書き込み¶

名前	説明
merge.query.id	ジャーナル・テーブルをターゲット・テーブルにマージするために使用されるクエリの ID。