ForkRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Beschreibung¶

Dieser Prozessor ermöglicht es dem Benutzer, einen Datensatz in mehrere Datensätze aufzuteilen. Der Benutzer muss mindestens einen Datensatzpfad als dynamische Eigenschaft angeben, der auf ein Feld vom Typ ARRAY verweist, das RECORD-Objekte enthält. Der Prozessor akzeptiert zwei Modi: „split“ und „extract“. In beiden Modi wird ein Datensatz pro Element in dem angegebenen Array erzeugt. Im „Split“-Modus behält jeder generierte Datensatz dasselbe Schema wie in der Eingabe angegeben, aber das Array enthält nur ein Element. Im Modus „extract“ muss das Element des Arrays vom Datensatztyp sein und wird zum generierten Datensatz. Zusätzlich können Sie im Modus „exract“ angeben, ob jeder generierte Datensatz alle Felder der übergeordneten Objekte von der Stammebene bis zum extrahierten Datensatz enthalten soll. Dabei wird davon ausgegangen, dass die Felder, die dem Datensatz hinzugefügt werden sollen, im Schema des Record Writer Controller-Dienstes definiert sind. Beispiele finden Sie in der Dokumentation für zusätzliche Details zu diesem Prozessor.

Tags¶

array, content, event, fork, record, stream

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
fork-mode	Gibt den Verzweigungsmodus des Prozessors an.
include-parent-fields	Dieser Parameter ist nur für den Modus „extract“ gültig. Wenn diese Option auf „true“ gesetzt ist, werden alle Felder von der Wurzelebene bis zum angegebenen Array als Felder jedes Elements des zu verzweigenden Arrays hinzugefügt.
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	Falls ein FlowFile während der Verzweigungsoperation einen Fehler erzeugt, wird es an diese Beziehung weitergeleitet.
fork	Die FlowFiles, die die verzweigten Datensätze enthalten, werden an diese Beziehung weitergeleitet.
original	Das Original-FlowFiles wird an diese Beziehung weitergeleitet.

Schreibt Attribute¶

Name	Beschreibung
record.count	Das erzeugte FlowFile hat ein Attribut „record.count“, das die Anzahl der Datensätze angibt, die in das FlowFile geschrieben wurden.
mime.type	Der vom Record Writer angegebene MIME-Typ
<Attributes from Record Writer>	Jedes Attribut, das der konfigurierte Record Writer zurückgibt, wird dem FlowFile hinzugefügt.