ConvertJSONToAvro

Description:

Converts JSON files to Avro according to an Avro Schema

Tags:

kite, json, avro

Properties:

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, and whether a property supports the NiFi Expression Language.

NameDefault ValueAllowable ValuesDescription
Hadoop configuration filesA comma-separated list of Hadoop configuration files
Record schemaOutgoing Avro schema for each record created from a JSON object
Supports Expression Language: true
Compression typeSNAPPY
  • BZIP2
  • DEFLATE
  • NONE
  • SNAPPY
  • LZO
Compression type to use when writting Avro files. Default is Snappy.

Relationships:

NameDescription
successAvro content that was converted successfully from JSON
failureJSON content that could not be processed
incompatibleJSON content that could not be converted

Reads Attributes:

None specified.

Writes Attributes:

None specified.

State management:

This component does not store state.

Restricted:

This component is not restricted.

Input requirement:

This component requires an incoming relationship.