MergeSnowflakeJournalTable 2025.5.31.15¶
バンドル¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
説明¶
Snowflakeのジャーナルテーブルから宛先テーブルへの変更に対するマージ演算子をトリガーします。マージ操作は非同期に実行され、演算子は操作の結果をポーリングします。クエリがまだ進行中の場合、フローファイルはペナルティを受けます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
宛先データベース名 |
データを取り込むSnowflakeデータベースの名前。 |
マージクエリの再試行回数 |
マージ・クエリが失敗した場合に何回再試行するかを示します。 |
Record Reader |
入力の読み取りに使用するRecord Reader |
Snowflake 接続プール |
Snowflakeデータベースへの接続を取得し、マージ処理を実行するために使用するController Service。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
ddl |
実行する DDL |
コンパクション中に削除された |
テーブル名と世代に基づいてコンパクション中に削除された FlowFile。 |
failure |
クエリ実行の失敗。 |
失敗リトライ |
クエリ実行の失敗を再試行します。 |
クエリ結果のポーリング |
スケジュールされた非同期クエリ実行。 |
success |
クエリの実行の成功。 |
不明なファイルタイプ |
不明なファイルタイプ。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
merge.query.id |
ジャーナル・テーブルをターゲット・テーブルにマージするために使用されるクエリの ID。 |