ExtractRecordSchema 2.3.0¶

BUNDLE¶

org.apache.nifi | nifi-standard-nar

DESCRIPTION¶

Extracts the record schema from the FlowFile using the supplied Record Reader and writes it to the avro.schema attribute.

TAGS¶

avro, csv, freeform, generic, json, record, schema, text, xml

INPUT REQUIREMENT¶

REQUIRED

Supports Sensitive Dynamic Properties¶

false

PROPERTIES¶

Property	Description
cache-size	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.
record-reader	Specifies the Controller Service to use for reading incoming data

RELATIONSHIPS¶

NAME	DESCRIPTION
failure	If a FlowFile’s record schema cannot be extracted from the configured input format, the FlowFile will be routed to this relationship
success	FlowFiles whose record schemas are successfully extracted will be routed to this relationship

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.