MergeSnowflakeJournalTable 2025.10.2.19¶

Bundle¶

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

Description¶

Déclenche une opération de fusion sur les modifications de la table de 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.
Résolution de l’identificateur d’objet	Contrôle la manière dont les identificateurs des objets sources (schémas, tables, colonnes) sont stockés et interrogés dans Snowflake. Ce paramètre détermine si vous devrez utiliser des guillemets doubles dans vos requêtes SQL. L’option « Sensible à la casse » est le comportement par défaut en production ; « Insensible à la casse » est considéré comme un comportement en avant-première pour le moment.
Valeur d’espaces réservés	Valeur de l’espace réservé de charge utile à rechercher dans un MERGE. Elle sera convertie en type de données de la colonne de destination.
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.
Stratégie de valeur inchangée	Détermine comment la requête MERGE doit traiter les valeurs inchangées dans les colonnes du journal. Par défaut, les valeurs complètes sont attendues.

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.