Used in conjunction with the JoinEnrichment processor, this processor is responsible for adding the attributes that are necessary for the JoinEnrichment processor to perform its function. Each incoming FlowFile will be cloned. The original FlowFile will have appropriate attributes added and then be transferred to the 'original' relationship. The clone will have appropriate attributes added and then be routed to the 'enrichment' relationship. See the documentation for the JoinEnrichment processor (and especially its Additional Details) for more information on how these Processors work together and how to perform enrichment tasks in NiFi by using these Processors.
fork, join, enrich, record
This component has no required or optional properties.
| Name | Description |
|---|---|
| enrichment | A clone of the incoming FlowFile will be routed to this relationship, after adding appropriate attributes. |
| original | The incoming FlowFile will be routed to this relationship, after adding appropriate attributes. |
| Name | Description |
|---|---|
| enrichment.group.id | The Group ID to use in order to correlate the 'original' FlowFile with the 'enrichment' FlowFile. |
| enrichment.role | The role to use for enrichment. This will either be ORIGINAL or ENRICHMENT. |