SnowflakeDetectDuplicate 2025.10.2.19¶
Bundle¶
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
Description¶
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.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Content Hash |
Le nom de l’attribut FlowFile qui contient le hachage précalculé. Prend en charge la langue d’expression. |
Document Source Identifier |
Spécifie l’identificateur de la source du document (doc ID). Prend en charge la langue d’expression. |
Document Source Name |
Indique le nom du système source de la documentation. Prend en charge la langue d’expression. |
Snowflake Connection Service |
Le DBCPService qui fournit la connectivité à Snowflake. |
Snowflake Table Name |
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. |
Relations¶
Nom |
Description |
|---|---|
distinct |
FlowFiles qui ne correspondent pas à une documentation existante sont routées ici (insertion d’un nouveau hachage). |
duplicate |
FlowFiles qui correspondent à une documentation existante (même hachage) sont routées ici. |
failure |
FlowFiles qui rencontrent une erreur ou une exception au cours du traitement sont routées ici. |
Écrit les attributs¶
Nom |
Description |
|---|---|
snowflake.detect.duplicate |
Un attribut “true” ou “false” indiquant si le FlowFile a été détecté comme étant un doublon. |