ForkRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Description¶

Ce processeur permet à l’utilisateur de diviser un enregistrement en plusieurs enregistrements. L’utilisateur doit spécifier au moins un chemin d’enregistrement, en tant que propriété dynamique, pointant vers un champ de type ARRAY contenant des objets RECORD. Le processeur accepte deux modes : split et extract. Dans les deux modes, un enregistrement est généré par élément contenu dans le tableau désigné. En mode « split », chaque enregistrement généré conservera le même schéma que celui indiqué dans l’entrée, mais le tableau ne contiendra qu’un seul élément. En mode « extraction », l’élément du tableau doit être de type enregistrement et sera l’enregistrement généré. En outre, dans le mode « extraction », il est possible de spécifier si chaque enregistrement généré doit contenir tous les champs des enregistrements parents depuis le niveau racine jusqu’à l’enregistrement extrait. Cela suppose que les champs à ajouter dans l’enregistrement sont définis dans le schéma du service de contrôleur Record Writer. Voir les exemples dans la documentation des détails supplémentaires de ce processeur.

Balises¶

array, content, event, fork, record, stream

Exigences en matière d’entrées¶

REQUIRED

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

false

Propriétés¶

Propriété	Description
fork-mode	Spécifie le mode de duplication du processeur
include-parent-fields	Ce paramètre n’est valable qu’en mode « extraction ». Si cette valeur est fixée à true, tous les champs du niveau racine au tableau donné seront ajoutés comme champs de chaque élément du tableau à dupliquer.
record-reader	Spécifie le Controller Service à utiliser pour la lecture des données entrantes
record-writer	Spécifie le Controller Service à utiliser pour la génération des enregistrements en sortie

Relations¶

Nom	Description
failure	Dans le cas où un FlowFile génère une erreur au cours de l’opération de duplication, il sera routé vers cette relation
fork	Le FlowFiles contenant les enregistrements forkés sera routé vers cette relation
original	Le FlowFiles original sera routé vers cette relation

Écrit les attributs¶

Nom	Description
record.count	Le FlowFile généré aura un attribut « record.count » indiquant le nombre d’enregistrements qui ont été écrits sur le FlowFile.
mime.type	Le type MIME indiqué par le Record Writer
<Attributs du Record Writer>	Tout attribut renvoyé par le Record Writer configuré sera ajouté au FlowFile.