ForkEnrichment

Description:

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.

Additional Details...

Tags:

fork, join, enrich, record

Properties:

This component has no required or optional properties.

Relationships:

NameDescription
enrichmentA clone of the incoming FlowFile will be routed to this relationship, after adding appropriate attributes.
originalThe incoming FlowFile will be routed to this relationship, after adding appropriate attributes.

Reads Attributes:

None specified.

Writes Attributes:

NameDescription
enrichment.group.idThe Group ID to use in order to correlate the 'original' FlowFile with the 'enrichment' FlowFile.
enrichment.roleThe role to use for enrichment. This will either be ORIGINAL or ENRICHMENT.

State management:

This component does not store state.

Restricted:

This component is not restricted.

Input requirement:

This component requires an incoming relationship.

System Resource Considerations:

None specified.

See Also:

JoinEnrichment