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
|
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 . |
Enum | Description |
---|---|
CompositeTypeSerializerSnapshot.OuterSchemaCompatibility |
Indicates schema compatibility of the serializer configuration persisted as the outer
snapshot.
|
Exception | Description |
---|---|
CompositeType.InvalidFieldReferenceException |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.