FetchTableSnapshot 2025.5.31.15¶
バンドル¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
説明¶
データベースからテーブルのスナップショットを取得します。スナップショットは、テーブルのプライマリキー列を使用して、バッチで行を取得するために、インクリメンタルに取得されます。プライマリ・キーのないテーブルの複製はサポートされていません。スナップショットは、指定された Record Writer 形式の FlowFile に書き込まれます。入力 FlowFile は、次の形式のテーブルスキーマの JSON 表現で構成されることが期待されます:{ "columns": [{ "name": "<column name>", "type": "<column type>" }, { "name": "<column name>", "type": "<column type>" }, ... ], "primaryKeys": ["<name of first primary key column>", "<name of second primary key column>", ...]}スキーマで指定された列のみがテーブルから取得されます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
---|---|
接続プール |
データベーススナップショットの取得に使用する接続プール。 |
フェッチサイズ |
一度にメモリにロードされる行の最大数 |
JDBC ドライバー 所在地 |
JAR ドライバーとその依存関係 (もしあれば) を含むファイル/フォルダおよび/または URLs のカンマ区切りリスト。例えば、'/var/tmp/postgresql-java-client-42.7.5.jar' です。 |
最大バッチサイズ |
バッチで取得する行の最大数。 |
Record Writer |
取得したスナップショットの書き込みに使用するRecord Writer |
スキーマ名 |
以下からスナップショットを取得するスキーマ名。 |
テーブル名 |
以下からスナップショットを取得するテーブル名。 |
リレーションシップ¶
名前 |
説明 |
---|---|
complete |
スナップショットが完了すると、元の FlowFile はこのリレーションシップにルーティングされます。 |
failure |
FlowFile で表されるテーブルからデータを取得できない場合、 FlowFile はこのリレーションシップにルーティングされます。 |
リトライ可能な失敗 |
FlowFile で表されるテーブルからデータを取得できないが、将来的に取得できるようになると予想される場合、 FlowFile はこのリレーションシップにルーティングされます。 |
rows |
スナップショットが FlowFile で表されるテーブルから正常に取得されると、行はこのリレーションシップにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
---|---|
snapshot.complete |
スナップショットが完了したかどうかを示します。 |
rows.total.fetched |
テーブルに対して取得された行の総数 |
rows.delta.fetched |
最後の反復でテーブルに取得された行数 |
start.row.index |
0から始まる、指定された反復のスナップショット内の最初の行のインデックス。 |
最終行インデックス |
0から始まる、与えられた反復のスナップショット内の最後の行のインデックス。 |
取得・デルタ・タイム (ミリ単位) |
最後の反復で行を取得するのにかかった時間 (ミリ秒単位) |
取得の合計時間 (ミリ単位) |
行の取得にかかった時間 (ミリ秒単位) |