ConvertAvroSchema

Description:

Convert records from one Avro schema to another, including support for flattening and simple type conversions

Additional Details...

Tags:

avro, convert, kite

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
Input SchemaAvro Schema of Input Flowfiles. This can be a URI (dataset, view, or resource) or literal JSON schema.
Supports Expression Language: true
Output SchemaAvro Schema of Output Flowfiles. This can be a URI (dataset, view, or resource) or literal JSON schema.
Supports Expression Language: true
LocaledefaultLocale to use for scanning data (see https://docs.oracle.com/javase/7/docs/api/java/util/Locale.html)or " default" for JVM default
Compression typeSNAPPY
  • BZIP2
  • DEFLATE
  • NONE
  • SNAPPY
  • LZO
Compression type to use when writting Avro files. Default is Snappy.

Dynamic Properties:

Dynamic Properties allow the user to specify both the name and value of a property.

NameValueDescription
Field name from input schemaField name for output schemaExplicit mappings from input schema to output schema, which supports renaming fields and stepping into nested records on the input schema using notation like parent.id

Relationships:

NameDescription
successAvro content that converted successfully
failureAvro content that failed to convert

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.