PickTablesForReplication 2025.10.2.19¶
バンドル¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
説明¶
Accepts a list of fully qualified table names and determines if a table: - is new (is not replicated, but was added in the source) - is existing (is replicated and exists in the source) - is stale (is replicated but no longer exists in the source) Configuration is passed as a FlowFile attribute. Processor generates a separate FlowFile for each source table.
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
テーブル状態サービス |
現在複製されているテーブルとその状態を含むサービス |
リレーションシップ¶
名前 |
説明 |
|---|---|
existing |
すでに複製されている修飾されたテーブル名の FlowFile |
failure |
FlowFile 属性が読み取れないか、間違っている場合、このリレーションシップにルーティングされます。 |
new |
複製されない修飾されたテーブル名の FlowFile |
stale |
以前は複製されていたが、ソースデータベースから削除されたか、パラメーターによって除外されたために複製されなくなったテーブル名を指定する FlowFile |
属性の書き込み¶
名前 |
説明 |
|---|---|
source.schema.name |
イベントの発生元テーブルのスキーマ名 |
source.table.name |
イベントの発生元テーブル名 |