PartitionRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Description¶

Fractionne, ou partitionne, les données orientées enregistrement en fonction des champs configurés dans les données. Une ou plusieurs propriétés doivent être ajoutées. Le nom de la propriété est le nom d’un attribut à ajouter. La valeur de la propriété est un RecordPath à évaluer par rapport à chaque enregistrement. Deux enregistrements seront envoyés au même FlowFile sortant uniquement s’ils ont la même valeur pour chacun des RecordPaths. Étant donné que nous savons que tous les enregistrements dans un FlowFile de sortie donné ont la même valeur pour les champs spécifiés par le RecordPath, un attribut est ajouté pour chaque champ. Voir Détails supplémentaires sur la page Utilisation pour plus d’informations et d’exemples.

Balises¶

bin, group, organize, partition, record, recordpath, rpath, segment, split

Exigences en matière d’entrées¶

REQUIRED

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

false

Propriétés¶

Propriété	Description
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	Si un FlowFile ne peut pas être partitionné du format d’entrée configuré vers le format de sortie configuré, le FlowFile inchangé sera acheminé vers cette relation.
original	Une fois que tous les enregistrements d’un FlowFile entrant ont été partitionnés, le FlowFile original est acheminé vers cette relation.
success	Les FlowFiles partitionnés avec succès seront acheminés vers cette relation.

Écrit les attributs¶

Nom	Description
record.count	Le nombre d’enregistrements dans un FlowFile sortant
mime.type	Le type MIME que le Record Writer configuré indique comme étant approprié
fragment.identifier	Tous les FlowFiles partitionnés produits à partir du même FlowFile parent auront le même UUID généré aléatoirement ajouté pour cet attribut.
fragment.index	Un numéro séquentiel indiquant l’ordre des FlowFiles partitionnés créés à partir d’un même FlowFile parent.
fragment.count	Le nombre de FlowFiles partitionnés générés à partir du FlowFile parent.
segment.original.filename	Le nom du FlowFile parent
<dynamic property name>	Pour chaque propriété dynamique ajoutée, un attribut peut être ajouté au FlowFile. Pour plus d’informations, reportez-vous à la description des propriétés dynamiques.

Cas d’utilisation¶

Séparer les enregistrements dans des FlowFiles distincts afin que tous les enregistrements d’un FlowFile aient la même valeur pour un champ ou un ensemble de champs donné.

Séparer les enregistrements selon qu’ils répondent ou non à un critère spécifique