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

Packages that use SimpleVersionedSerializer

Package	Description
org.apache.flink.api.connector.sink
org.apache.flink.api.connector.sink2
org.apache.flink.api.connector.source
org.apache.flink.api.connector.source.lib
org.apache.flink.core.fs
org.apache.flink.core.fs.local
org.apache.flink.core.io

Uses of SimpleVersionedSerializer in org.apache.flink.api.connector.sink

Methods in org.apache.flink.api.connector.sink that return types with arguments of type SimpleVersionedSerializer

Modifier and Type	Method	Description
Optional<SimpleVersionedSerializer<CommT>>	Sink.getCommittableSerializer()	Deprecated. Returns the serializer of the committable type.
Optional<SimpleVersionedSerializer<GlobalCommT>>	Sink.getGlobalCommittableSerializer()	Deprecated. Returns the serializer of the aggregated committable type.
Optional<SimpleVersionedSerializer<WriterStateT>>	Sink.getWriterStateSerializer()	Deprecated. Any stateful sink needs to provide this state serializer and implement SinkWriter.snapshotState(long) properly.

Uses of SimpleVersionedSerializer in org.apache.flink.api.connector.sink2

Methods in org.apache.flink.api.connector.sink2 that return SimpleVersionedSerializer

Modifier and Type	Method	Description
SimpleVersionedSerializer<CommittableT>	SupportsCommitter.getCommittableSerializer()	Returns the serializer of the committable type.
SimpleVersionedSerializer<WriterStateT>	SupportsWriterState.getWriterStateSerializer()	Any stateful sink needs to provide this state serializer and implement StatefulSinkWriter.snapshotState(long) properly.

Uses of SimpleVersionedSerializer in org.apache.flink.api.connector.source

Methods in org.apache.flink.api.connector.source that return SimpleVersionedSerializer

Modifier and Type	Method	Description
SimpleVersionedSerializer<EnumChkT>	Source.getEnumeratorCheckpointSerializer()	Creates the serializer for the SplitEnumerator checkpoint.
SimpleVersionedSerializer<SplitT>	Source.getSplitSerializer()	Creates a serializer for the source splits.

Uses of SimpleVersionedSerializer in org.apache.flink.api.connector.source.lib

Methods in org.apache.flink.api.connector.source.lib that return SimpleVersionedSerializer

Modifier and Type	Method	Description
SimpleVersionedSerializer<Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.getEnumeratorCheckpointSerializer()
SimpleVersionedSerializer<NumberSequenceSource.NumberSequenceSplit>	NumberSequenceSource.getSplitSerializer()

Uses of SimpleVersionedSerializer in org.apache.flink.core.fs

Methods in org.apache.flink.core.fs that return SimpleVersionedSerializer

Modifier and Type	Method	Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	RecoverableWriter.getCommitRecoverableSerializer()	The serializer for the CommitRecoverable types created in this writer.
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	RecoverableWriter.getResumeRecoverableSerializer()	The serializer for the ResumeRecoverable types created in this writer.

Uses of SimpleVersionedSerializer in org.apache.flink.core.fs.local

Methods in org.apache.flink.core.fs.local that return SimpleVersionedSerializer

Modifier and Type	Method	Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	LocalRecoverableWriter.getCommitRecoverableSerializer()
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	LocalRecoverableWriter.getResumeRecoverableSerializer()

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

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

Modifier and Type	Class	Description
class	SimpleVersionedSerializerAdapter<T>	Adapter for TypeSerializer to SimpleVersionedSerializer.

Methods in org.apache.flink.core.io with parameters of type SimpleVersionedSerializer

Modifier and Type	Method	Description
static <T> T	SimpleVersionedSerialization.readVersionAndDeSerialize(SimpleVersionedSerializer<T> serializer, byte[] bytes)	Deserializes the version and datum from a byte array.
static <T> T	SimpleVersionedSerialization.readVersionAndDeSerialize(SimpleVersionedSerializer<T> serializer, DataInputView in)	Deserializes the version and datum from a stream.
static <T> List<T>	SimpleVersionedSerialization.readVersionAndDeserializeList(SimpleVersionedSerializer<T> serializer, DataInputView in)	Deserializes the version and data from a stream.
static <T> byte[]	SimpleVersionedSerialization.writeVersionAndSerialize(SimpleVersionedSerializer<T> serializer, T datum)	Serializes the version and datum into a byte array.
static <T> void	SimpleVersionedSerialization.writeVersionAndSerialize(SimpleVersionedSerializer<T> serializer, T datum, DataOutputView out)	Serializes the version and datum into a stream.
static <T> void	SimpleVersionedSerialization.writeVersionAndSerializeList(SimpleVersionedSerializer<T> serializer, List<T> data, DataOutputView out)	Serializes the version and data into a stream.

Constructor parameters in org.apache.flink.core.io with type arguments of type SimpleVersionedSerializer

Constructor	Description
SimpleVersionedSerializerTypeSerializerProxy(org.apache.flink.util.function.SerializableSupplier<SimpleVersionedSerializer<T>> serializerSupplier)