ForkEnrichment 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Beschreibung¶
In Verbindung mit dem JoinEnrichment-Prozessor ist dieser Prozessor für das Hinzufügen der Attribute zuständig, die der JoinEnrichment -Prozessor benötigt, um seine Funktion zu erfüllen. Jedes eingehende FlowFile wird geklont. Dem Original-FlowFile werden die entsprechenden Attribute hinzugefügt, und es wird dann in die Beziehung „original“ übertragen. Dem Klon werden die entsprechenden Attribute hinzugefügt, und er wird dann an die Beziehung „enrichment“ weitergeleitet. In der Dokumentation zum JoinEnrichment -Prozessor (und insbesondere in den zusätzlichen Details) finden Sie weitere Informationen darüber, wie diese Prozessoren zusammenarbeiten und wie Sie mit Hilfe dieser Prozessoren Anreicherungsaufgaben in NiFi durchführen können.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Beziehungen¶
Name |
Beschreibung |
|---|---|
enrichment |
Ein Klon des eingehenden FlowFile wird an diese Beziehung weitergeleitet, nachdem die entsprechenden Attribute hinzugefügt wurden. |
original |
Das eingehende FlowFile wird an diese Beziehung weitergeleitet, nachdem die entsprechenden Attribute hinzugefügt wurden. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
enrichment.group.id |
Die zu verwendende Gruppen-ID, um das Original-FlowFile mit dem „enrichment“-FlowFile zu korrelieren. |
enrichment.role |
Die für die Anreicherung zu verwendende Rolle. Dies wird entweder ORIGINAL oder ENRICHMENT sein. |