RecordReaderFactory
Implementations: ScriptedReader
ReaderLookup
YamlTreeReader
CSVReader
AvroReader
SyslogReader
ProtobufReader
GrokReader
Syslog5424Reader
JsonPathReader
JsonTreeReader
XMLReader
CEFReader
ExcelReader
WindowsEventLogReader
The Record Reader to use parsing the incoming FlowFile into Records | Record Writer | Record Writer | | Controller Service API: RecordSetWriterFactory Implementations: AvroRecordSetWriter XMLRecordSetWriter ScriptedRecordSetWriter JsonRecordSetWriter CSVRecordSetWriter RecordSetWriterLookup FreeFormTextRecordSetWriter | The Record Writer to use for serializing Records after they have been transformed |
Script Language | Script Engine | Groovy | | The Language to use for the script |
Script Body | Script Body | | | Body of script to execute. Only one of Script File or Script Body may be used |
Script File | Script File | | | Path to script file to execute. Only one of Script File or Script Body may be used
This property requires exactly one file to be provided..
Supports Expression Language: true (will be evaluated using Environment variables only) |
Module Directory | Module Directory | | | Comma-separated list of paths to files and/or directories which contain modules required by the script.
This property expects a comma-separated list of resources. Each of the resources may be of any of the following types: directory, file.
Supports Expression Language: true (will be evaluated using Environment variables only) |
Relationships:
Name | Description |
---|
success | Each FlowFile that were successfully transformed will be routed to this Relationship |
failure | Any FlowFile that cannot be transformed will be routed to this Relationship |
Reads Attributes:
None specified.Writes Attributes:
Name | Description |
---|
mime.type | Sets the mime.type attribute to the MIME Type specified by the Record Writer |
record.count | The number of records in the FlowFile |
record.error.message | This attribute provides on failure the error message encountered by the Reader or Writer. |
State management:
This component does not store state.Restricted:
Required Permission | Explanation |
---|
execute code | Provides operator the ability to execute arbitrary code assuming all permissions that NiFi has. |
Input requirement:
This component requires an incoming relationship.System Resource Considerations:
None specified.See Also:
ExecuteScript, UpdateRecord, QueryRecord, JoltTransformRecord, LookupRecord