MergeSnowflakeJournalTable 2025.5.31.15¶

Bundle¶

com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar

Description¶

Déclenche une opération de fusion sur les modifications de la table du journal vers une table de destination dans Snowflake. L’opération de fusion est effectuée de manière asynchrone et le processeur interroge le résultat de l’opération. Si la requête est toujours en cours, le FlowFile sera pénalisé.

Balises¶

Exigences en matière d’entrées¶

REQUIRED

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Destination Database Name	Le nom de la base de données Snowflake dans laquelle les données sont ingérées.
Merge Query Retry Count	Indique combien de fois la requête de fusion doit être relancée en cas d’échec.
Record Reader	Le Record Reader à utiliser pour lire l’entrée
Snowflake Connection Pool	Le Controller Service qui est utilisé pour obtenir une connexion à la base de données de Snowflake afin d’effectuer l’opération de fusion.

Relations¶

Nom	Description
ddl	DDL à exécuter.
deleted during compaction	FlowFile supprimé lors du compactage en fonction du nom de la table et de la génération.
failure	Échec de l’exécution de la requête.
failure retry	Réessayer l’exécution de la requête en cas d’échec.
poll query result	Exécution planifiée de requêtes asynchrones.
success	Exécution réussie de la requête.
unknown file type	Type de fichier inconnu.

Écrit les attributs¶

Nom	Description
merge.query.id	L’ID de la requête utilisée pour fusionner la table journal dans la table cible.