PartitionRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Beschreibung¶

Teilt oder partitioniert datensatzorientierte Daten basierend auf den konfigurierten Feldern in den Daten. Eine oder mehrere Eigenschaften müssen hinzugefügt werden. Der Name der Eigenschaft ist der Name eines Attributs, das hinzugefügt werden soll. Der Wert der Eigenschaft ist ein RecordPath, der gegen jeden Datensatz ausgewertet wird. Zwei Datensätze gehen nur dann an denselben Ausgangs-FlowFile, wenn sie für jede der angegebenen RecordPaths denselben Wert haben. Da wir wissen, dass alle Datensätze in einer bestimmten FlowFile-Ausgabe denselben Wert für die Felder haben, die durch den RecordPath angegeben sind, wird für jedes Feld ein Attribut hinzugefügt. Weitere Informationen und Beispiele finden Sie unter „Weitere Details“ auf der Seite „Verwendung“.

Tags¶

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

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
record-reader	Gibt den Controller Service an, der zum Lesen eingehender Daten verwendet werden soll
record-writer	Gibt den Controller Service an, der für das Schreiben der Datensätze verwendet werden soll

Beziehungen¶

Name	Beschreibung
failure	Wenn ein FlowFile nicht vom konfigurierten Eingabeformat in das konfigurierte Ausgabeformat partitioniert werden kann, wird das unveränderte FlowFile an diese Beziehung weitergeleitet.
original	Sobald alle Datensätze in einem eingehenden FlowFile partitioniert wurden, wird das Original-FlowFile an diese Beziehung weitergeleitet.
success	FlowFiles, die erfolgreich partitioniert wurden, werden an diese Beziehung weitergeleitet.

Schreibt Attribute¶

Name	Beschreibung
record.count	Die Anzahl der Datensätze in einem ausgehenden FlowFile
mime.type	Der MIME-Typ, den der konfigurierte Record Writer angibt, ist geeignet
fragment.identifier	Alle partitionierten FlowFiles, die aus demselben übergeordneten FlowFile erzeugt wurden, werden mit demselben zufällig generierten UUID für dieses Attribut versehen.
fragment.index	Eine aufsteigende Nummer, die die Reihenfolge der partitionierten FlowFiles angibt, die aus einem einzigen übergeordneten FlowFile erstellt wurden.
fragment.count	Die Anzahl der partitionierten FlowFiles, die aus dem übergeordneten FlowFile generiert werden.
segment.original.filename	Der Dateiname des übergeordneten FlowFile
<dynamic property name>	Für jede dynamische Eigenschaft, die hinzugefügt wird, kann ein Attribut zum FlowFile hinzugefügt werden. Weitere Informationen finden Sie in der Beschreibung für dynamische Eigenschaften.

Anwendungsfälle¶

Trennen Sie Datensätze in separate FlowFiles, sodass alle Datensätze in einem FlowFile denselben Wert für ein bestimmtes Feld oder eine bestimmte Gruppe von Feldern haben.

Trennen Sie Datensätze danach, ob sie einem bestimmten Kriterium entsprechen oder nicht