Modifier and Type | Class and Description |
---|---|
static class |
CompositeSerializer.ConfigSnapshot
Deprecated.
this snapshot class is no longer in use by any serializers, and is only kept
around for backwards compatibility. All subclass serializers should have their own
serializer snapshot classes.
|
class |
CompositeTypeSerializerConfigSnapshot<T>
A
TypeSerializerConfigSnapshot for serializers that has multiple nested serializers. |
class |
GenericTypeSerializerConfigSnapshot<T>
Configuration snapshot for serializers for generic types.
|
class |
ParameterlessTypeSerializerConfig<T>
Deprecated.
this snapshot class is no longer used by any serializers, and is maintained only for
backward compatibility reasons. It is fully replaced by
SimpleTypeSerializerSnapshot . |
class |
TypeSerializerConfigSnapshot<T>
Deprecated.
|
static class |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy<T>
Deprecated.
Utility serialization proxy for a
TypeSerializer . |
Modifier and Type | Class and Description |
---|---|
class |
CollectionSerializerConfigSnapshot<C extends Collection<T>,T>
Deprecated.
this snapshot class should no longer be used by any serializers as their snapshot.
|
static class |
EnumSerializer.EnumSerializerConfigSnapshot<T extends Enum<T>>
Deprecated.
|
class |
MapSerializerConfigSnapshot<K,V>
Deprecated.
this snapshot class should not be used by any serializer anymore.
|
Modifier and Type | Class and Description |
---|---|
static class |
CopyableValueSerializer.CopyableValueSerializerConfigSnapshot<T extends CopyableValue<T>>
Deprecated.
|
class |
EitherSerializerConfigSnapshot<L,R>
Deprecated.
|
class |
KryoRegistrationSerializerConfigSnapshot<T>
Configuration snapshot base class for serializers that use Kryo for serialization.
|
static class |
NullableSerializer.NullableSerializerConfigSnapshot<T>
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards
compatibility purposes. It is fully replaced by
NullableSerializer.NullableSerializerSnapshot . |
static class |
PojoSerializer.PojoSerializerConfigSnapshot<T>
Deprecated.
This snapshot class is no longer being used. It has been fully replaced by
PojoSerializerSnapshot . |
static class |
RowSerializer.RowSerializerConfigSnapshot
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards
compatibility. It is fully replaced by
RowSerializer.RowSerializerSnapshot . |
class |
TupleSerializerConfigSnapshot<T>
Snapshot of a tuple serializer's configuration.
|
static class |
ValueSerializer.ValueSerializerConfigSnapshot<T extends Value>
Deprecated.
|
static class |
WritableSerializer.WritableSerializerConfigSnapshot<T extends org.apache.hadoop.io.Writable>
Deprecated.
This class is no longer used as a snapshot for any serializer. It is fully
replaced by
WritableSerializer.WritableSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
KryoSerializer.KryoSerializerConfigSnapshot<T>
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ScalaOptionSerializerConfigSnapshot<E>
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards
compatibility. It is fully replaced by
ScalaOptionSerializerSnapshot . |
class |
ScalaTrySerializerConfigSnapshot<E>
Deprecated.
|
class |
TraversableSerializerConfigSnapshot<T extends scala.collection.TraversableOnce<E>,E>
Deprecated.
This is being replaced with
TraversableSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
NFA.NFASerializerConfigSnapshot<T>
Deprecated.
This snapshot class is no longer in use, and only maintained for backwards
compatibility purposes. It is fully replaced by
NFA.MigratedNFASerializerSnapshot . |
static class |
SharedBuffer.SharedBufferSerializerConfigSnapshot<K,V>
Deprecated.
This snapshot class is no longer in use, and only maintained for backwards
compatibility purposes. It is fully replaced by
SharedBuffer.SharedBufferSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
class |
AsyncSinkWriterStateSerializer<RequestEntryT extends Serializable>
Serializer class for
AsyncSinkWriter state. |
Modifier and Type | Class and Description |
---|---|
class |
HybridSourceEnumeratorStateSerializer
The
Serializer for the enumerator state. |
class |
HybridSourceSplitSerializer
Serializes splits by delegating to the source-indexed underlying split serializer.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSinkCommittableSerializer
Versioned serializer for
FileSinkCommittable . |
Modifier and Type | Class and Description |
---|---|
class |
CompactorRequestSerializer
Versioned serializer for
CompactorRequest . |
Modifier and Type | Class and Description |
---|---|
class |
FileWriterBucketStateSerializer
A
SimpleVersionedSerializer used to serialize the BucketState . |
Modifier and Type | Class and Description |
---|---|
class |
FileSourceSplitSerializer
A serializer for the
FileSourceSplit . |
class |
PendingSplitsCheckpointSerializer<T extends FileSourceSplit>
A serializer for the
PendingSplitsCheckpoint . |
Modifier and Type | Class and Description |
---|---|
class |
KinesisFirehoseStateSerializer
Kinesis Firehose implementation
AsyncSinkWriterStateSerializer . |
Modifier and Type | Class and Description |
---|---|
class |
KafkaSourceEnumStateSerializer
The
Serializer for the enumerator
state of Kafka source. |
Modifier and Type | Class and Description |
---|---|
class |
KafkaPartitionSplitSerializer
The
serializer for KafkaPartitionSplit . |
Modifier and Type | Class and Description |
---|---|
class |
KinesisStreamsStateSerializer
Kinesis Streams implementation
AsyncSinkWriterStateSerializer . |
Modifier and Type | Class and Description |
---|---|
class |
PulsarCommittableSerializer
A serializer used to serialize
PulsarCommittable . |
Modifier and Type | Class and Description |
---|---|
class |
PulsarSourceEnumStateSerializer
The
Serializer for the enumerator state of Pulsar source. |
Modifier and Type | Class and Description |
---|---|
class |
PulsarPartitionSplitSerializer
The
serializer for PulsarPartitionSplit . |
Modifier and Type | Class and Description |
---|---|
class |
NoOpEnumStateSerializer
Mock enumerator state serializer.
|
Modifier and Type | Class and Description |
---|---|
class |
FromElementsSplitSerializer
The split serializer for the
FromElementsSource . |
Modifier and Type | Class and Description |
---|---|
class |
ContinuousHivePendingSplitsCheckpointSerializer
SerDe for
ContinuousHivePendingSplitsCheckpoint . |
class |
HiveSourceSplitSerializer
SerDe for
HiveSourceSplit . |
Modifier and Type | Interface and Description |
---|---|
interface |
SimpleVersionedSerializer<E>
A simple serializer interface for versioned serialization.
|
Modifier and Type | Class and Description |
---|---|
class |
PostVersionedIOReadableWritable
A
VersionedIOReadableWritable which allows to differentiate whether the previous data was
versioned with a VersionedIOReadableWritable . |
class |
VersionedIOReadableWritable
This is the abstract base class for
IOReadableWritable which allows to differentiate
between serialization versions. |
Modifier and Type | Class and Description |
---|---|
class |
OSSRecoverableSerializer
Serializer implementation for a
OSSRecoverable . |
Modifier and Type | Interface and Description |
---|---|
interface |
MetadataSerializer
Deserializer for checkpoint metadata.
|
Modifier and Type | Class and Description |
---|---|
class |
MetadataV1Serializer
Deserializer for checkpoints written in format
1 (Flink 1.2.x format). |
class |
MetadataV2Serializer
(De)serializer for checkpoint metadata format version 2.
|
class |
MetadataV3Serializer
(De)serializer for checkpoint metadata format version 3.
|
class |
MetadataV4Serializer
V4 serializer that adds
CheckpointProperties
serialization. |
Modifier and Type | Class and Description |
---|---|
class |
KeyedBackendSerializationProxy<K>
Serialization proxy for all meta data in keyed state backends.
|
class |
OperatorBackendSerializationProxy
Serialization proxy for all meta data in operator state backends.
|
Modifier and Type | Class and Description |
---|---|
class |
CommittableMessageSerializer<CommT>
The serializer to serialize
CommittableMessage s in custom operators. |
Modifier and Type | Class and Description |
---|---|
static class |
CoGroupedStreams.UnionSerializerConfigSnapshot<T1,T2>
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards
compatibility. It is fully replaced by
CoGroupedStreams.UnionSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot<TXN,CONTEXT>
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards
compatibility purposes. It is fully replaced by
TwoPhaseCommitSinkFunction.StateSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverableSerializer
The serializer for
OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable . |
static class |
OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverableSerializer
The serializer for
OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverable . |
Modifier and Type | Class and Description |
---|---|
class |
SimpleVersionedStringSerializer
A
SimpleVersionedSerializer implementation for Strings. |
Modifier and Type | Class and Description |
---|---|
class |
InternalTimerServiceSerializationProxy<K>
Serialization proxy for the timer services for a given key-group.
|
static class |
TimerSerializer.TimerSerializerConfigSnapshot<K,N>
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards
compatibility purposes. It is fully replaced by
TimerSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
IntervalJoinOperator.BufferSerializerConfigSnapshot<T>
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards
compatibility. It is fully replaced by
IntervalJoinOperator.BufferEntrySerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
class |
CommittableCollectorSerializer<CommT>
The serializer for the
CommittableCollector . |
Modifier and Type | Class and Description |
---|---|
static class |
StreamElementSerializer.StreamElementSerializerConfigSnapshot<T>
Deprecated.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.