SplitRecord 2025.5.31.15

Bundle

org.apache.nifi | nifi-standard-nar

Beschreibung

Teilt ein Eingabe-FlowFile, das in einem datensatzorientierten Datenformat vorliegt, in mehrere kleinere FlowFiles.

Tags

avro, csv, freeform, generic, json, log, logs, schema, split, text

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

Records Per Split

Gibt an, wie viele Datensätze in jedes „aufgeteilte“ oder „Segment“-Flowfile geschrieben werden sollen.

Beziehungen

Name

Beschreibung

failure

Wenn ein FlowFile nicht vom konfigurierten Eingabeformat in das konfigurierte Ausgabeformat umgewandelt werden kann, wird das unveränderte FlowFile an diese Beziehung weitergeleitet.

original

Nach erfolgreicher Aufteilung eines Eingabe-FlowFile wird das Original-FlowFile an diese Beziehung gesendet.

Splits

Die einzelnen „Segmente“ des Original-FlowFile werden an diese Beziehung weitergeleitet.

Schreibt Attribute

Name

Beschreibung

mime.type

Setzt das Attribut mime.type für die FlowFiles, das an die Beziehung „splits“ weitergeleitet wird, auf den vom Record Writer angegebenen MIME-Typ.

record.count

Die Anzahl der Datensätze im FlowFile. Dies wird zu FlowFiles hinzugefügt, die an die Beziehung „splits“ weitergeleitet werden.

fragment.identifier

Alle geteilten FlowFiles, die aus demselben übergeordneten FlowFile erzeugt werden, erhalten dieselbe zufällig generierte UUID für dieses Attribut

fragment.index

Eine aufsteigende Nummer, die die Reihenfolge der aufgeteilten FlowFiles angibt, die aus einem einzigen übergeordneten FlowFile erstellt wurden.

fragment.count

Die Anzahl der aus dem übergeordneten FlowFile generierten FlowFiles

segment.original.filename

Der Dateiname des übergeordneten FlowFile