EnrichCdcStream 2025.10.2.19¶
バンドル¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
説明¶
Enriches incoming FlowFiles that come from CaptureChangePostgreSQL, etc. with information pertaining to which Journal Table to write to and relevant schema information. This Processor manages the schema versions for each table being processed in order to ensure that the correct Journal Table is used for each FlowFile.
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
CDC スキーマレジストリ |
CDC データのスキーマ管理に使用する CDC スキーマレジストリを指定します。 |
Record Reader |
受信データの読み取りに使用するRecord Readerを指定します。 |
Record Writer |
送信データの書き込みに使用するRecord Writerを指定します。 |
テーブル状態サービス |
複製テーブルの状態を保持 |
状態管理¶
スコープ |
説明 |
|---|---|
CLUSTER |
処理中の各テーブルの現在のジャーナル・テーブル・バージョンを追跡します。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
FlowFile が読み取れない場合は、この Relationship にルーティングされます。 |
スキーマ更新 |
受信記録を処理するためにスキーマの更新が必要な場合、 FlowFile がこのリレーションシップにルーティングされます。FlowFile には、どのような変更が必要かを示すスキーマ情報が含まれます。 |
スキップされたddlイベント |
このリレーションシップは、デスティネーション・テーブルのスキーマを変更しない DDL / スキーマ変更イベントに使用されます。 |
success |
Snowflakeテーブルに挿入される行は、このリレーションシップにルーティングされます。 |
状態にないテーブル |
FlowFile は、複製されたテーブルの状態に存在しないテーブルをリファレンスする場合に使用されます（おそらく複製から削除された後）。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
table.schema.generation |
インクリメンタル処理用のジャーナル・テーブルのインデックス。 |
table.schema.initial |
ジャーナル・テーブルの初期生成を示します。 |
destination.table.schema |
宛先テーブルの更新スキーマ。この属性は DDL イベントに対してのみ記述されます。 |