Uses of Interface
org.apache.flink.core.io.Versioned

Packages that use Versioned

Package	Description
org.apache.flink.connector.base.sink.writer
org.apache.flink.connector.base.source.hybrid
org.apache.flink.connector.file.sink
org.apache.flink.connector.file.sink.compactor.operator
org.apache.flink.connector.file.sink.writer
org.apache.flink.connector.file.src
org.apache.flink.connector.testframe.source.enumerator
org.apache.flink.connector.testframe.source.split
org.apache.flink.connectors.hive
org.apache.flink.core.io
org.apache.flink.fs.osshadoop.writer
org.apache.flink.runtime.checkpoint.metadata
org.apache.flink.runtime.jobmaster.event
org.apache.flink.runtime.state
org.apache.flink.streaming.api.connector.sink2
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.operators.sink.committables

Uses of Versioned in org.apache.flink.connector.base.sink.writer

Classes in org.apache.flink.connector.base.sink.writer that implement Versioned

Modifier and Type	Class and Description
class	AsyncSinkWriterStateSerializer<RequestEntryT extends Serializable> Serializer class for AsyncSinkWriter state.

Uses of Versioned in org.apache.flink.connector.base.source.hybrid

Classes in org.apache.flink.connector.base.source.hybrid that implement Versioned

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.

Uses of Versioned in org.apache.flink.connector.file.sink

Classes in org.apache.flink.connector.file.sink that implement Versioned

Modifier and Type	Class and Description
class	FileSinkCommittableSerializer Versioned serializer for FileSinkCommittable.

Uses of Versioned in org.apache.flink.connector.file.sink.compactor.operator

Classes in org.apache.flink.connector.file.sink.compactor.operator that implement Versioned

Modifier and Type	Class and Description
class	CompactorRequestSerializer Versioned serializer for CompactorRequest.

Uses of Versioned in org.apache.flink.connector.file.sink.writer

Classes in org.apache.flink.connector.file.sink.writer that implement Versioned

Modifier and Type	Class and Description
class	FileWriterBucketStateSerializer A SimpleVersionedSerializer used to serialize the BucketState.

Uses of Versioned in org.apache.flink.connector.file.src

Classes in org.apache.flink.connector.file.src that implement Versioned

Modifier and Type	Class and Description
class	FileSourceSplitSerializer A serializer for the FileSourceSplit.
class	PendingSplitsCheckpointSerializer<T extends FileSourceSplit> A serializer for the PendingSplitsCheckpoint.

Uses of Versioned in org.apache.flink.connector.testframe.source.enumerator

Classes in org.apache.flink.connector.testframe.source.enumerator that implement Versioned

Modifier and Type	Class and Description
class	NoOpEnumStateSerializer Mock enumerator state serializer.

Uses of Versioned in org.apache.flink.connector.testframe.source.split

Classes in org.apache.flink.connector.testframe.source.split that implement Versioned

Modifier and Type	Class and Description
class	FromElementsSplitSerializer The split serializer for the FromElementsSource.

Uses of Versioned in org.apache.flink.connectors.hive

Classes in org.apache.flink.connectors.hive that implement Versioned

Modifier and Type	Class and Description
class	ContinuousHivePendingSplitsCheckpointSerializer SerDe for ContinuousHivePendingSplitsCheckpoint.
class	HiveSourceSplitSerializer SerDe for HiveSourceSplit.
class	HiveTablePartitionSerializer SerDe for HiveTablePartition.

Uses of Versioned in org.apache.flink.core.io

Subinterfaces of Versioned in org.apache.flink.core.io

Modifier and Type	Interface and Description
interface	SimpleVersionedSerializer<E> A simple serializer interface for versioned serialization.

Classes in org.apache.flink.core.io that implement Versioned

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.

Uses of Versioned in org.apache.flink.fs.osshadoop.writer

Classes in org.apache.flink.fs.osshadoop.writer that implement Versioned

Modifier and Type	Class and Description
class	OSSRecoverableSerializer Serializer implementation for a OSSRecoverable.

Uses of Versioned in org.apache.flink.runtime.checkpoint.metadata

Subinterfaces of Versioned in org.apache.flink.runtime.checkpoint.metadata

Modifier and Type	Interface and Description
interface	MetadataSerializer Deserializer for checkpoint metadata.

Classes in org.apache.flink.runtime.checkpoint.metadata that implement Versioned

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.

Uses of Versioned in org.apache.flink.runtime.jobmaster.event

Classes in org.apache.flink.runtime.jobmaster.event that implement Versioned

Modifier and Type	Class and Description
class	GenericJobEventSerializer Serializer for JobEvent instances that uses Flink's InstantiationUtil for serialization and deserialization.

Uses of Versioned in org.apache.flink.runtime.state

Classes in org.apache.flink.runtime.state that implement Versioned

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.

Uses of Versioned in org.apache.flink.streaming.api.connector.sink2

Classes in org.apache.flink.streaming.api.connector.sink2 that implement Versioned

Modifier and Type	Class and Description
class	CommittableMessageSerializer<CommT> The serializer to serialize CommittableMessages in custom operators.

Uses of Versioned in org.apache.flink.streaming.api.functions.sink.filesystem

Classes in org.apache.flink.streaming.api.functions.sink.filesystem that implement Versioned

Modifier and Type	Class and Description
static class	OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverableSerializer The serializer for OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable.
static class	OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverableSerializer The serializer for OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverable.

Uses of Versioned in org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners

Classes in org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners that implement Versioned

Modifier and Type	Class and Description
class	SimpleVersionedStringSerializer A SimpleVersionedSerializer implementation for Strings.

Uses of Versioned in org.apache.flink.streaming.api.operators

Classes in org.apache.flink.streaming.api.operators that implement Versioned

Modifier and Type	Class and Description
class	InternalTimerServiceSerializationProxy<K> Serialization proxy for the timer services for a given key-group.

Uses of Versioned in org.apache.flink.streaming.runtime.operators.sink.committables

Classes in org.apache.flink.streaming.runtime.operators.sink.committables that implement Versioned

Modifier and Type	Class and Description
class	CommittableCollectorSerializer<CommT> The serializer for the CommittableCollector.