Interface | Description |
---|---|
CompositeType.TypeComparatorBuilder<T> | |
LegacySerializerSnapshotTransformer<T> |
This interface provides a way for
TypeSerializer s to transform a legacy TypeSerializerSnapshot
used in versions before Flink 1.7 during deserialization. |
TypeComparatorFactory<T> | |
TypePairComparatorFactory<T1,T2> | |
TypeSerializerConfigSnapshot.SelfResolvingTypeSerializer<E> |
This interface assists with the migration path to the new serialization abstraction.
|
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. |
CompositeSerializer<T> |
Base class for composite serializers.
|
CompositeSerializer.ConfigSnapshot | Deprecated
this snapshot class is no longer in use by any serializers, and is only
kept around for backwards compatibility.
|
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> | |
CompositeTypeSerializerConfigSnapshot<T> |
A
TypeSerializerConfigSnapshot for serializers that has multiple nested serializers. |
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> | |
GenericTypeSerializerConfigSnapshot<T> |
Configuration snapshot for serializers for generic types.
|
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.
|
ParameterlessTypeSerializerConfig<T> | Deprecated
this snapshot class is no longer used by any serializers, and is maintained only
for backward compatibility reasons.
|
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.
|
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.