Extracts the record schema from the FlowFile using the supplied Record Reader and writes it to the `avro.schema` attribute.
record, generic, schema, json, csv, avro, freeform, text, xml
In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values.
| Display Name | API Name | Default Value | Allowable Values | Description |
|---|---|---|---|---|
| Record Reader | record-reader | Controller Service API: RecordReaderFactory Implementations: GrokReader JsonTreeReader WindowsEventLogReader ReaderLookup ParquetReader CSVReader Syslog5424Reader ExcelReader CEFReader XMLReader ScriptedReader SyslogReader JsonPathReader AvroReader YamlTreeReader | 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. |
| 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 |
| 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. |