ScriptedPartitionRecord 2.3.0¶

BUNDLE¶

org.apache.nifi | nifi-scripting-nar

DESCRIPTION¶

Receives Record-oriented data (i.e., data that can be read by the configured Record Reader) and evaluates the user provided script against each record in the incoming flow file. Each record is then grouped with other records sharing the same partition and a FlowFile is created for each groups of records. Two records shares the same partition if the evaluation of the script results the same return value for both. Those will be considered as part of the same partition.

TAGS¶

groovy, group, organize, partition, record, script, segment, split

INPUT REQUIREMENT¶

Supports Sensitive Dynamic Properties¶

false

PROPERTIES¶

Property	Description
Module Directory	Comma-separated list of paths to files and/or directories which contain modules required by the script.
Record Reader	The Record Reader to use parsing the incoming FlowFile into Records
Record Writer	The Record Writer to use for serializing Records after they have been transformed
Script Body	Body of script to execute. Only one of Script File or Script Body may be used
Script Engine	The Language to use for the script
Script File	Path to script file to execute. Only one of Script File or Script Body may be used

RESTRICTIONS¶

REQUIRED PERMISSION	EXPLANATION
execute code	Provides operator the ability to execute arbitrary code assuming all permissions that NiFi has.

RELATIONSHIPS¶

NAME	DESCRIPTION
success	FlowFiles that are successfully partitioned will be routed to this relationship
failure	If a FlowFile cannot be partitioned from the configured input format to the configured output format, the unchanged FlowFile will be routed to this relationship
original	Once all records in an incoming FlowFile have been partitioned, the original FlowFile is routed to this relationship.

WRITES ATTRIBUTES¶

NAME	DESCRIPTION
partition	The partition of the outgoing flow file. If the script indicates that the partition has a null value, the attribute will be set to the literal string “<null partition>” (without quotes). Otherwise, the attribute is set to the String representation of whatever value is returned by the script.
mime.type	Sets the mime.type attribute to the MIME Type specified by the Record Writer
record.count	The number of records within the flow file.
record.error.message	This attribute provides on failure the error message encountered by the Reader or Writer.
fragment.index	A one-up number that indicates the ordering of the partitioned FlowFiles that were created from a single parent FlowFile
fragment.count	The number of partitioned FlowFiles generated from the parent FlowFile