org.apache.flink.formats.avro.typeutils

Class AvroTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase>

java.lang.Object

org.apache.flink.api.common.typeinfo.TypeInformation<T>

org.apache.flink.api.common.typeutils.CompositeType<T>

org.apache.flink.api.java.typeutils.PojoTypeInfo<T>

org.apache.flink.formats.avro.typeutils.AvroTypeInfo<T>

All Implemented Interfaces:

Serializable

public class AvroTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase>
extends PojoTypeInfo<T>

Special type information to generate a special AvroTypeInfo for Avro POJOs (implementing SpecificRecordBase, the typed Avro POJOs)

Proceeding: It uses a regular pojo type analysis and replaces all GenericType<CharSequence> with a GenericType<avro.Utf8>. All other types used by Avro are standard Java types. Only strings are represented as CharSequence fields and represented as Utf8 classes at runtime. CharSequence is not comparable. To make them nicely usable with field expressions, we replace them here by generic type infos containing Utf8 classes (which are comparable),

This class is checked by the AvroPojoTest.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.java.typeutils.PojoTypeInfo

PojoTypeInfo.NamedFlatFieldDescriptor

Nested classes/interfaces inherited from class org.apache.flink.api.common.typeutils.CompositeType

CompositeType.FlatFieldDescriptor, CompositeType.InvalidFieldReferenceException, CompositeType.TypeComparatorBuilder<T>

Constructor Summary

Constructors

Constructor and Description
AvroTypeInfo(Class<T> typeClass) Creates a new Avro type info for the given class.

Method Summary

Modifier and Type	Method and Description
TypeSerializer<T>	createSerializer(ExecutionConfig config) Create TypeSerializer for this type.
TypeSerializer<T>	createSerializer(SerializerConfig config) Creates a serializer for the type.

Methods inherited from class org.apache.flink.api.java.typeutils.PojoTypeInfo

canEqual, createPojoSerializer, createPojoSerializer, createTypeComparatorBuilder, equals, getArity, getFieldIndex, getFieldNames, getFlatFields, getPojoFieldAt, getTotalFields, getTypeAt, getTypeAt, hashCode, isBasicType, isSortKeyType, isTupleType, toString

Methods inherited from class org.apache.flink.api.common.typeutils.CompositeType

createComparator, getFlatFields, getTypeClass, hasDeterministicFieldOrder, hasField, isKeyType

Methods inherited from class org.apache.flink.api.common.typeinfo.TypeInformation

getGenericParameters, of, of

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AvroTypeInfo

public AvroTypeInfo(Class<T> typeClass)

Creates a new Avro type info for the given class.

Method Detail

createSerializer

public TypeSerializer<T> createSerializer(SerializerConfig config)

Description copied from class: TypeInformation

Creates a serializer for the type. The serializer may use the ExecutionConfig for parameterization.

Overrides:

createSerializer in class PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase>

Parameters:

config - The config used to parameterize the serializer.

Returns:

A serializer for this type.

createSerializer

public TypeSerializer<T> createSerializer(ExecutionConfig config)

Description copied from class: TypeInformation

Create TypeSerializer for this type.

Overrides:

createSerializer in class PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase>

Parameters:

config - the configuration of this job execution