JoltTransformRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-jolt-nar

Beschreibung¶

Wendet eine JOLT-Spezifikation auf jeden Datensatz in der FlowFile-Nutzlast an. Es wird ein neues FlowFile mit umgewandeltem Inhalt erstellt und an die Beziehung „success“ weitergeleitet. Wenn die Umwandlung fehlschlägt, wird das Original-FlowFile an die Beziehung „failure“ weitergeleitet.

Tags¶

cardinality, chainr, defaultr, jolt, record, removr, shiftr, sort, transform

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Custom Module Directory	Eine durch Kommas getrennte Liste von Pfaden zu Dateien und/oder Verzeichnissen, die Module mit benutzerdefinierten Transformationen enthalten (die nicht im Klassenpfad von NiFi enthalten sind).
Custom Transformation Class Name	Vollständig qualifizierter Klassenname für benutzerdefinierte Transformation
Jolt Specification	Jolt Spezifikation für die Transformation von JSON-Daten. Der Wert für diese Eigenschaft kann der Text einer Jolt-Spezifikation oder der Pfad zu einer Datei sein, die eine Jolt-Spezifikation enthält. „Jolt Specification“ muss festgelegt sein, sonst wird der Wert ignoriert, wenn die Jolt-Sortierung ausgewählt ist.
Jolt Transform	Gibt die Jolt-Transformation an, die mit der angegebenen Spezifikation verwendet werden soll.
Transform Cache Size	Das Kompilieren einer Jolt-Transformation kann ziemlich teuer sein. Im Idealfall wird dies nur einmal gemacht. Wenn jedoch die Expression Language in der Transformation verwendet wird, benötigen wir möglicherweise für jedes FlowFile eine neue Transformation. Dieser Wert steuert, wie viele dieser Transformationen wir im Speicher zwischenspeichern, um zu vermeiden, dass die Transformation jedes Mal neu kompiliert werden muss.
jolt-record-record-reader	Gibt den Controller Service an, der für das Parsen eingehender Daten und die Bestimmung des Datenschemas verwendet werden soll.
jolt-record-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 aus irgendeinem Grund nicht verarbeitet werden kann (z. B. weil die FlowFile-Datensätze nicht geparst werden können), wird es an diese Beziehung weitergeleitet.
original	Das Original-FlowFile nach der Transformation. Wenn die Verarbeitung des FlowFile fehlschlägt, wird nichts an diese Beziehung gesendet.
success	Das FlowFile mit transformiertem Inhalt wird 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