ForkEnrichment 2025.5.31.15

Bundle

org.apache.nifi | nifi-standard-nar

Description

Utilisé conjointement avec le processeur JoinEnrichment, ce processeur est chargé d’ajouter les attributs nécessaires à l’accomplissement de la fonction du processeur JoinEnrichment. Chaque FlowFile entrant sera cloné. Les attributs appropriés seront ajoutés au FlowFile original et seront ensuite transférés dans la relation « originale ». Les attributs appropriés seront ajoutés au clone, qui sera ensuite routé vers la relation d’enrichissement. Consultez la documentation relative au processeur JoinEnrichment (et en particulier la section Détails supplémentaires) pour obtenir de plus amples informations sur la manière dont ces processeurs fonctionnent ensemble et sur la manière d’effectuer des tâches d’enrichissement dans NiFi à l’aide de ces processeurs.

Balises

enrich, fork, join, record

Exigences en matière d’entrées

REQUIRED

Prend en charge les propriétés dynamiques sensibles

false

Relations

Nom

Description

enrichment

Un clone du FlowFile entrant sera routé vers cette relation, après ajout des attributs appropriés.

original

Le FlowFile sera routé vers cette relation, après l’ajout des attributs appropriés.

Écrit les attributs

Nom

Description

enrichment.group.id

L’ID de groupe à utiliser pour établir une corrélation entre le site FlowFile original et le FlowFile enrichi.

enrichment.role

Le rôle à utiliser pour l’enrichissement. Il s’agira soit de ORIGINAL, soit de ENRICHMENT.

Voir aussi :