Package org.apache.flink.api.common.typeutils

Interface Summary

Interface	Description
CompositeType.TypeComparatorBuilder<T>
LegacySerializerSnapshotTransformer<T>	This interface provides a way for TypeSerializers to transform a legacy TypeSerializerSnapshot used in versions before Flink 1.7 during deserialization.
TypeComparatorFactory<T>
TypePairComparatorFactory<T1,T2>
TypeSerializerFactory<T>
TypeSerializerSnapshot<T>	A TypeSerializerSnapshot is a point-in-time view of a TypeSerializer's configuration.

Class Summary

Class	Description
CompositeSerializer<T>	Base class for composite serializers.
CompositeSerializer.PrecomputedParameters	This class holds composite serializer parameters which can be precomputed in advanced for better performance.
CompositeType<T>	Base type information class for Tuple and Pojo types The class is taking care of serialization and comparators for Tuples as well.
CompositeType.FlatFieldDescriptor
CompositeTypeComparator<T>
CompositeTypeSerializerSnapshot<T,S extends TypeSerializer<T>>	A CompositeTypeSerializerSnapshot is a convenient serializer snapshot class that can be used by simple serializers which 1) delegates its serialization to multiple nested serializers, and 2) may contain some extra static information that needs to be persisted as part of its snapshot.
CompositeTypeSerializerUtil	Utilities for the CompositeTypeSerializerSnapshot.
CompositeTypeSerializerUtil.IntermediateCompatibilityResult<T>
GenericPairComparator<T1,T2>
GenericTypeSerializerSnapshot<T,S extends TypeSerializer>	Base TypeSerializerSnapshot for serializers for generic types.
NestedSerializersSnapshotDelegate	A NestedSerializersSnapshotDelegate represents the snapshots of multiple serializers that are used by an outer serializer.
SameTypePairComparator<T>
SimpleTypeSerializerSnapshot<T>	A simple base class for TypeSerializerSnapshots, for serializers that have no parameters.
SingleThreadAccessCheckingTypeSerializer<T>
SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessCheckingTypeSerializerSnapshot<T>
TypeComparator<T>	This interface describes the methods that are required for a data type to be handled by the pact runtime.
TypePairComparator<T1,T2>	This interface defines the method required by the runtime to use data types in join-like operations.
TypeSerializer<T>	This interface describes the methods that are required for a data type to be handled by the Flink runtime.
TypeSerializerSchemaCompatibility<T>	A TypeSerializerSchemaCompatibility represents information about whether or not a TypeSerializer can be safely used to read data written by a previous type serializer.
TypeSerializerSnapshotSerializationUtil	Utility methods for serialization of TypeSerializerSnapshot.
TypeSerializerUtils	Utilities for dealing with the TypeSerializer and the TypeSerializerSnapshot.
UnloadableDummyTypeSerializer<T>	Dummy TypeSerializer to avoid that data is lost when checkpointing again a serializer for which we encountered a ClassNotFoundException or InvalidClassException.

Enum Summary

Enum	Description
CompositeTypeSerializerSnapshot.OuterSchemaCompatibility	Indicates schema compatibility of the serializer configuration persisted as the outer snapshot.

Exception Summary

Exception	Description
CompositeType.InvalidFieldReferenceException