SnowflakeDetectDuplicate 2025.10.2.19¶
バンドル¶
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
説明¶
Checks if a FlowFile 's hash (provided as a FlowFile attribute) is already in a Snowflake table, and routes the FlowFile to' duplicate 'if found,'distinct 'if not found, or' failure' on errors.
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
コンテンツ・ハッシュ |
事前に計算されたハッシュを保持する FlowFile 属性の名前。式言語をサポートしています。 |
ドキュメントソース識別子 |
ドキュメントソース識別子 (doc ID) を指定します。式言語をサポートしています。 |
ドキュメントソース名 |
ドキュメントソースシステム名を指定します。式言語をサポートしています。 |
Snowflake 接続 サービス |
Snowflakeへの接続を提供する DBCPService。 |
Snowflakeテーブルネーム |
The Snowflake table name that stores the file hashes. The table name is case-insensitive. Database and schema must be configured prior in the Snowflake Connection Service. |
リレーションシップ¶
名前 |
説明 |
|---|---|
distinct |
既存のドキュメントにマッチしない FlowFiles はここにルーティングされます (新しいハッシュが挿入されます)。 |
duplicate |
既存のドキュメント (同じハッシュ) にマッチする FlowFiles はここにルーティングされます。 |
failure |
処理中にエラーや例外が発生した FlowFiles は、ここにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
Snowflake.detect.duplicate |
FlowFile が重複として検出されたかどうかを示す 'true' または 'false' 属性。 |