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> | |
TypeSerializerSnapshot<T> |
A
TypeSerializerSnapshot is a point-in-time view of a TypeSerializer 's configuration. |
Class | Description |
---|---|
BackwardsCompatibleSerializerSnapshot<T> |
A utility
TypeSerializerConfigSnapshot that is used for backwards compatibility purposes. |
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 | Deprecated
this utility class still uses the old serializer compatibility interfaces, and
is therefore deprecated.
|
CompositeSerializer<T> |
Base class for composite serializers.
|
CompositeSerializer.ConfigSnapshot |
Snapshot field serializers of composite type.
|
CompositeSerializer.PrecomputedParameters |
This class holds composite serializer parameters which can be precomputed in advanced for better performance.
|
CompositeSerializerSnapshot |
A CompositeSerializerSnapshot represents the snapshots of multiple serializers that are used
by an outer serializer.
|
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<T> |
A
TypeSerializerConfigSnapshot for serializers that has multiple nested serializers. |
GenericPairComparator<T1,T2> | |
GenericTypeSerializerConfigSnapshot<T> |
Configuration snapshot for serializers for generic types.
|
ParameterlessTypeSerializerConfig<T> |
A base class for
TypeSerializerConfigSnapshot s that do not have any parameters. |
SameTypePairComparator<T> | |
SimpleTypeSerializerSnapshot<T> |
A simple base class for TypeSerializerSnapshots, for serializers that have no
parameters.
|
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<T> | Deprecated |
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. |
TypeSerializerSerializationUtil | Deprecated
This utility class was used to write serializers into checkpoints.
|
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy<T> |
Utility serialization proxy for a
TypeSerializer . |
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 . |
Exception | Description |
---|---|
CompositeType.InvalidFieldReferenceException |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.