org.apache.flink.formats.avro.typeutils

Class AvroSchemaConverter

java.lang.Object

org.apache.flink.formats.avro.typeutils.AvroSchemaConverter

public class AvroSchemaConverter
extends Object

Converts an Avro schema into Flink's type information. It uses RowTypeInfo for representing objects and converts Avro types into types that are compatible with Flink's Table & SQL API.

Note: Changes in this class need to be kept in sync with the corresponding runtime classes AvroRowDeserializationSchema and AvroRowSerializationSchema.

Method Summary

Modifier and Type	Method and Description
static <T extends org.apache.avro.specific.SpecificRecord> org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row>	convertToTypeInfo(Class<T> avroClass) Converts an Avro class into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.
static <T> org.apache.flink.api.common.typeinfo.TypeInformation<T>	convertToTypeInfo(String avroSchemaString) Converts an Avro schema string into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

convertToTypeInfo

public static <T extends org.apache.avro.specific.SpecificRecord> org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> convertToTypeInfo(Class<T> avroClass)

Converts an Avro class into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.

Parameters:

avroClass - Avro specific record that contains schema information

Returns:

type information matching the schema

convertToTypeInfo

public static <T> org.apache.flink.api.common.typeinfo.TypeInformation<T> convertToTypeInfo(String avroSchemaString)

Converts an Avro schema string into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.

Parameters:

avroSchemaString - Avro schema definition string

Returns:

type information matching the schema