RecordReaderFactory
Implementations: AvroReader
ScriptedReader
XMLReader
ExcelReader
ParquetReader
JsonTreeReader
WindowsEventLogReader
YamlTreeReader
ReaderLookup
JsonPathReader
ProtobufReader
CSVReader
CEFReader
SyslogReader
Syslog5424Reader
GrokReader
Specifies the Controller Service to use for reading incoming data | Schema Cache Size | cache-size | 10 | | Specifies the number of schemas to cache. This value should reflect the expected number of different schemas that may be in the incoming FlowFiles. This ensures more efficient retrieval of the schemas and thus the processor performance. |
Relationships:
Name | Description |
---|
success | FlowFiles whose record schemas are successfully extracted will be routed to this relationship |
failure | If a FlowFile's record schema cannot be extracted from the configured input format, the FlowFile will be routed to this relationship |
Reads Attributes:
None specified.Writes Attributes:
Name | Description |
---|
record.error.message | This attribute provides on failure the error message encountered by the Reader. |
avro.schema | This attribute provides the schema extracted from the input FlowFile using the provided RecordReader. |
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.