|Specifies the Controller Service to use for reading incoming data|
|Record Writer||Controller Service API: |
|Specifies the Controller Service to use for writing out the records|
|Merge Strategy||Bin-Packing Algorithm|
- Bin-Packing Algorithm
|Specifies the algorithm used to merge records. The 'Defragment' algorithm combines fragments that are associated by attributes back into a single cohesive FlowFile. The 'Bin-Packing Algorithm' generates a FlowFile populated by arbitrarily chosen FlowFiles|
|Correlation Attribute Name||If specified, two FlowFiles will be binned together only if they have the same value for this Attribute. If not specified, FlowFiles are bundled by the order in which they are pulled from the queue.|
|Attribute Strategy||Keep Only Common Attributes|
- Keep Only Common Attributes
- Keep All Unique Attributes
|Determines which FlowFile attributes should be added to the bundle. If 'Keep All Unique Attributes' is selected, any attribute on any FlowFile that gets bundled will be kept unless its value conflicts with the value from another FlowFile. If 'Keep Only Common Attributes' is selected, only the attributes that exist on all FlowFiles in the bundle, with the same value, will be preserved.|
|Minimum Number of Records||1||The minimum number of records to include in a bin|
|Maximum Number of Records||1000||The maximum number of Records to include in a bin. This is a 'soft limit' in that if a FlowFIle is added to a bin, all records in that FlowFile will be added, so this limit may be exceeded by up to the number of records in the last input FlowFile.|
|Minimum Bin Size||0 B||The minimum size of for the bin|
|Maximum Bin Size||The maximum size for the bundle. If not specified, there is no maximum. This is a 'soft limit' in that if a FlowFile is added to a bin, all records in that FlowFile will be added, so this limit may be exceeded by up to the number of bytes in last input FlowFile.|
|Max Bin Age||The maximum age of a Bin that will trigger a Bin to be complete. Expected format is <duration> <time unit> where <duration> is a positive integer and time unit is one of seconds, minutes, hours|
|Maximum Number of Bins||10||Specifies the maximum number of bins that can be held in memory at any one time. This number should not be smaller than the maximum number of conurrent threads for this Processor, or the bins that are created will often consist only of a single incoming FlowFile.|
|failure||If the bundle cannot be created, all FlowFiles that would have been used to created the bundle will be transferred to failure|
|original||The FlowFiles that were used to create the bundle|
|merged||The FlowFile containing the merged records|
|fragment.identifier||Applicable only if the <Merge Strategy> property is set to Defragment. All FlowFiles with the same value for this attribute will be bundled together.|
|fragment.count||Applicable only if the <Merge Strategy> property is set to Defragment. This attribute must be present on all FlowFiles with the same value for the fragment.identifier attribute. All FlowFiles in the same bundle must have the same value for this attribute. The value of this attribute indicates how many FlowFiles should be expected in the given bundle.|
|record.count||The merged FlowFile will have a 'record.count' attribute indicating the number of records that were written to the FlowFile.|
|mime.type||The MIME Type indicated by the Record Writer|
|merge.count||The number of FlowFiles that were merged into this bundle|
|merge.bin.age||The age of the bin, in milliseconds, when it was merged and output. Effectively this is the greatest amount of time that any FlowFile in this bundle remained waiting in this processor before it was output|
|<Attributes from Record Writer>||Any Attribute that the configured Record Writer returns will be added to the FlowFile.|
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.
MergeContent, SplitRecord, PartitionRecord