Interface | Description |
---|---|
CompositeType.TypeComparatorBuilder<T> | |
TypeComparatorFactory<T> | |
TypeDeserializer<T> |
This interface describes the methods that are required for a data type to be read by the Flink runtime.
|
TypePairComparatorFactory<T1,T2> | |
TypeSerializerFactory<T> |
Class | Description |
---|---|
CompatibilityResult<T> |
A
CompatibilityResult contains information about whether or not data migration
is required in order to continue using new serializers for previously serialized data. |
CompatibilityUtil |
Utilities related to serializer compatibility.
|
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> | |
CompositeTypeSerializerConfigSnapshot |
A
TypeSerializerConfigSnapshot for serializers that has multiple nested serializers. |
GenericPairComparator<T1,T2> | |
GenericTypeSerializerConfigSnapshot<T> |
Configuration snapshot for serializers for generic types.
|
ParameterlessTypeSerializerConfig |
A base class for
TypeSerializerConfigSnapshot s that do not have any parameters. |
SameTypePairComparator<T> | |
TypeComparator<T> |
This interface describes the methods that are required for a data type to be handled by the pact
runtime.
|
TypeDeserializerAdapter<T> |
A utility class that is used to bridge a
TypeSerializer and TypeDeserializer . |
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.
|
TypeSerializerConfigSnapshot |
A
TypeSerializerConfigSnapshot is a point-in-time view of a TypeSerializer's configuration. |
TypeSerializerSerializationUtil |
Utility methods for serialization of
TypeSerializer and TypeSerializerConfigSnapshot . |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy<T> |
Utility serialization proxy for a
TypeSerializer . |
UnloadableDummyTypeSerializer<T> |
Dummy TypeSerializer to avoid that data is lost when checkpointing again a serializer for which we encountered
a
ClassNotFoundException or InvalidClassException . |
Exception | Description |
---|---|
CompositeType.InvalidFieldReferenceException | |
UnloadableTypeSerializerException |
An exception thrown to indicate that a serializer cannot be read.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.