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.connector.base.sink.writer
org.apache.flink.connector.base.source.hybrid
org.apache.flink.connector.base.source.utils
org.apache.flink.connector.datagen.source
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.file.table
org.apache.flink.connector.testframe.source
org.apache.flink.connector.testframe.source.enumerator
org.apache.flink.connector.testframe.source.split
org.apache.flink.connectors.hive
org.apache.flink.core.fs
org.apache.flink.core.fs.local
org.apache.flink.core.io
org.apache.flink.fs.gs.writer
org.apache.flink.fs.osshadoop.writer
org.apache.flink.fs.s3.common.writer
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.fs.hdfs
org.apache.flink.runtime.jobmaster.event
org.apache.flink.runtime.source.coordinator
org.apache.flink.runtime.source.event
org.apache.flink.sql.tests
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.api.operators.util
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.runtime.operators.sink.committables
org.apache.flink.table.examples.java.connectors

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 and 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 and 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 and 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 and Description
SimpleVersionedSerializer<Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.getEnumeratorCheckpointSerializer()
SimpleVersionedSerializer<NumberSequenceSource.NumberSequenceSplit>	NumberSequenceSource.getSplitSerializer()

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

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

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

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

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

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.

Methods in org.apache.flink.connector.base.source.hybrid that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<HybridSourceEnumeratorState>	HybridSource.getEnumeratorCheckpointSerializer()
SimpleVersionedSerializer<HybridSourceSplit>	HybridSource.getSplitSerializer()

Uses of SimpleVersionedSerializer in org.apache.flink.connector.base.source.utils

Methods in org.apache.flink.connector.base.source.utils with parameters of type SimpleVersionedSerializer

Modifier and Type	Method and Description
static <SplitT extends SourceSplit,C extends Collection<SplitT>> Map<Integer,C>	SerdeUtils.deserializeSplitAssignments(byte[] serialized, SimpleVersionedSerializer<SplitT> splitSerializer, Function<Integer,C> collectionSupplier) Deserialize the given bytes returned by SerdeUtils.serializeSplitAssignments(Map, SimpleVersionedSerializer).
static <SplitT extends SourceSplit,C extends Collection<SplitT>> byte[]	SerdeUtils.serializeSplitAssignments(Map<Integer,C> splitAssignments, SimpleVersionedSerializer<SplitT> splitSerializer) Serialize a mapping from subtask ids to lists of assigned splits.

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

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

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

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

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

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

Methods in org.apache.flink.connector.file.sink that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<FileSinkCommittable>	FileSink.getCommittableSerializer()
SimpleVersionedSerializer<String>	FileSinkProgram.KeyBucketAssigner.getSerializer()
SimpleVersionedSerializer<FileSinkCommittable>	FileSink.getWriteResultSerializer()
SimpleVersionedSerializer<FileWriterBucketState>	FileSink.getWriterStateSerializer()

Constructors in org.apache.flink.connector.file.sink with parameters of type SimpleVersionedSerializer

Constructor and Description
FileSinkCommittableSerializer(SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileSerializer, SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileSerializer)
FileSinkCommittableSerializer(SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileSerializer, SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileSerializer)

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

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

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

Constructors in org.apache.flink.connector.file.sink.compactor.operator with parameters of type SimpleVersionedSerializer

Constructor and Description
CompactCoordinator(FileCompactStrategy strategy, SimpleVersionedSerializer<FileSinkCommittable> committableSerializer)
CompactCoordinatorStateHandler(SimpleVersionedSerializer<FileSinkCommittable> committableSerializer)
CompactorOperator(FileCompactStrategy strategy, SimpleVersionedSerializer<FileSinkCommittable> committableSerializer, FileCompactor fileCompactor, BucketWriter<?,String> bucketWriter)
CompactorOperatorStateHandler(SimpleVersionedSerializer<FileSinkCommittable> committableSerializer, BucketWriter<?,String> bucketWriter)
CompactorRequestSerializer(SimpleVersionedSerializer<FileSinkCommittable> committableSerializer)

Constructor parameters in org.apache.flink.connector.file.sink.compactor.operator with type arguments of type SimpleVersionedSerializer

Constructor and Description
CompactCoordinatorFactory(FileCompactStrategy strategy, SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier)
CompactCoordinatorStateHandlerFactory(SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier)
CompactorOperatorFactory(FileCompactStrategy strategy, FileCompactor fileCompactor, SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier, SerializableSupplierWithException<BucketWriter<?,String>,IOException> bucketWriterProvider)
CompactorOperatorStateHandlerFactory(SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier, SerializableSupplierWithException<BucketWriter<?,String>,IOException> bucketWriterProvider)
CompactorRequestTypeInfo(SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier)

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

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

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

Constructors in org.apache.flink.connector.file.sink.writer with parameters of type SimpleVersionedSerializer

Constructor and Description
FileWriterBucketStateSerializer(SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileRecoverableSerializer, SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileRecoverableSerializer)
FileWriterBucketStateSerializer(SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileRecoverableSerializer, SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileRecoverableSerializer)

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

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

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

Methods in org.apache.flink.connector.file.src that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<PendingSplitsCheckpoint<SplitT>>	AbstractFileSource.getEnumeratorCheckpointSerializer()
abstract SimpleVersionedSerializer<SplitT>	AbstractFileSource.getSplitSerializer()
SimpleVersionedSerializer<FileSourceSplit>	FileSource.getSplitSerializer()

Constructors in org.apache.flink.connector.file.src with parameters of type SimpleVersionedSerializer

Constructor and Description
PendingSplitsCheckpointSerializer(SimpleVersionedSerializer<T> splitSerializer)

Uses of SimpleVersionedSerializer in org.apache.flink.connector.file.table

Methods in org.apache.flink.connector.file.table that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<String>	FileSystemTableSink.TableBucketAssigner.getSerializer()

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

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

Modifier and Type	Method and Description
SimpleVersionedSerializer<NoOpEnumState>	FromElementsSource.getEnumeratorCheckpointSerializer()
SimpleVersionedSerializer<FromElementsSplit>	FromElementsSource.getSplitSerializer()

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

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

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

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

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

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

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

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

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

Methods in org.apache.flink.connectors.hive that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<PendingSplitsCheckpoint<HiveSourceSplit>>	HiveSource.getEnumeratorCheckpointSerializer()
SimpleVersionedSerializer<HiveSourceSplit>	HiveSource.getSplitSerializer()

Constructors in org.apache.flink.connectors.hive with parameters of type SimpleVersionedSerializer

Constructor and Description
ContinuousHivePendingSplitsCheckpointSerializer(SimpleVersionedSerializer<HiveSourceSplit> splitSerDe)

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

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

Modifier and Type	Method and 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 and Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	LocalRecoverableWriter.getCommitRecoverableSerializer()
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	LocalRecoverableWriter.getResumeRecoverableSerializer()

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

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

Modifier and Type	Method and 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 and Description
SimpleVersionedSerializerTypeSerializerProxy(SerializableSupplier<SimpleVersionedSerializer<T>> serializerSupplier)

Uses of SimpleVersionedSerializer in org.apache.flink.fs.gs.writer

Methods in org.apache.flink.fs.gs.writer that return SimpleVersionedSerializer

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

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

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

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

Methods in org.apache.flink.fs.osshadoop.writer that return SimpleVersionedSerializer

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

Uses of SimpleVersionedSerializer in org.apache.flink.fs.s3.common.writer

Methods in org.apache.flink.fs.s3.common.writer that return SimpleVersionedSerializer

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

Uses of SimpleVersionedSerializer in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<T>	MasterTriggerRestoreHook.createCheckpointDataSerializer() Creates a the serializer to (de)serializes the data stored by this hook.

Uses of SimpleVersionedSerializer in org.apache.flink.runtime.fs.hdfs

Methods in org.apache.flink.runtime.fs.hdfs that return SimpleVersionedSerializer

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

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

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

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

Uses of SimpleVersionedSerializer in org.apache.flink.runtime.source.coordinator

Methods in org.apache.flink.runtime.source.coordinator with parameters of type SimpleVersionedSerializer

Modifier and Type	Method and Description
void	SplitAssignmentTracker.restoreState(SimpleVersionedSerializer<SplitT> splitSerializer, byte[] assignmentData) Restore the state of the SplitAssignmentTracker.
byte[]	SplitAssignmentTracker.snapshotState(SimpleVersionedSerializer<SplitT> splitSerializer) Take a snapshot of the split assignments.

Constructors in org.apache.flink.runtime.source.coordinator with parameters of type SimpleVersionedSerializer

Constructor and Description
SourceCoordinatorContext(SourceCoordinatorProvider.CoordinatorExecutorThreadFactory coordinatorThreadFactory, int numWorkerThreads, OperatorCoordinator.Context operatorCoordinatorContext, SimpleVersionedSerializer<SplitT> splitSerializer, boolean supportsConcurrentExecutionAttempts)

Uses of SimpleVersionedSerializer in org.apache.flink.runtime.source.event

Methods in org.apache.flink.runtime.source.event with parameters of type SimpleVersionedSerializer

Modifier and Type	Method and Description
List<SplitT>	AddSplitEvent.splits(SimpleVersionedSerializer<SplitT> splitSerializer)

Constructors in org.apache.flink.runtime.source.event with parameters of type SimpleVersionedSerializer

Constructor and Description
AddSplitEvent(List<SplitT> splits, SimpleVersionedSerializer<SplitT> splitSerializer)

Uses of SimpleVersionedSerializer in org.apache.flink.sql.tests

Methods in org.apache.flink.sql.tests that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<String>	StreamSQLTestProgram.KeyBucketAssigner.getSerializer()

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

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

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

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

Modifier and Type	Method and Description
SimpleVersionedSerializer<WriterResultT>	SupportsPreCommitTopology.getWriteResultSerializer() Returns the serializer of the WriteResult type.
default SimpleVersionedSerializer<CommT>	WithPreCommitTopology.getWriteResultSerializer() Deprecated. Defaults to SupportsCommitter.getCommittableSerializer() for backward compatibility.

Method parameters in org.apache.flink.streaming.api.connector.sink2 with type arguments of type SimpleVersionedSerializer

Modifier and Type	Method and Description
static <CommT> void	StandardSinkTopologies.addGlobalCommitter(DataStream<CommittableMessage<CommT>> committables, SerializableSupplier<Committer<CommT>> committerFactory, SerializableSupplier<SimpleVersionedSerializer<CommT>> committableSerializer) Adds a global committer to the pipeline that runs as final operator with a parallelism of one.
static <CommT> TypeInformation<CommittableMessage<CommT>>	CommittableMessageTypeInfo.of(SerializableSupplier<SimpleVersionedSerializer<CommT>> committableSerializerFactory) Returns the type information based on the serializer for a CommittableMessage.

Constructors in org.apache.flink.streaming.api.connector.sink2 with parameters of type SimpleVersionedSerializer

Constructor and Description
CommittableMessageSerializer(SimpleVersionedSerializer<CommT> committableSerializer)

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

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

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

Methods in org.apache.flink.streaming.api.functions.sink.filesystem that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable>	OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverableSerializer.getCommitSerializer()
SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable>	WriterProperties.getInProgressFileRecoverableSerializer()
SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable>	WriterProperties.getPendingFileRecoverableSerializer()
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable>	OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverableSerializer.getResumeSerializer()
SimpleVersionedSerializer<BucketID>	BucketAssigner.getSerializer()

Constructors in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type SimpleVersionedSerializer

Constructor and Description
WriterProperties(SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileRecoverableSerializer, SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileRecoverableSerializer, boolean supportsResume)
WriterProperties(SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileRecoverableSerializer, SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileRecoverableSerializer, boolean supportsResume)

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

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

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

Methods in org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<String>	BasePathBucketAssigner.getSerializer()
SimpleVersionedSerializer<String>	DateTimeBucketAssigner.getSerializer()

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

Constructors in org.apache.flink.streaming.api.operators with parameters of type SimpleVersionedSerializer

Constructor and Description

SourceOperator(FunctionWithException<SourceReaderContext,SourceReader<OUT,SplitT>,Exception> readerFactory, OperatorEventGateway operatorEventGateway, SimpleVersionedSerializer<SplitT> splitSerializer, WatermarkStrategy<OUT> watermarkStrategy, ProcessingTimeService timeService, Configuration configuration, String localHostname, boolean emitProgressiveWatermarks, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)

Uses of SimpleVersionedSerializer in org.apache.flink.streaming.api.operators.util

Constructors in org.apache.flink.streaming.api.operators.util with parameters of type SimpleVersionedSerializer

Constructor and Description
SimpleVersionedListState(ListState<byte[]> rawState, SimpleVersionedSerializer<T> serializer) Creates a new SimpleVersionedListState that reads and writes bytes from the given raw ListState with the given serializer.

Uses of SimpleVersionedSerializer in org.apache.flink.streaming.api.transformations

Methods in org.apache.flink.streaming.api.transformations that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<GlobalCommT>	SinkV1Adapter.GlobalCommitterAdapter.getGlobalCommittableSerializer()

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

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

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

Methods in org.apache.flink.streaming.runtime.operators.sink.committables with parameters of type SimpleVersionedSerializer

Modifier and Type	Method and Description
static <T> List<T>	SinkV1CommittableDeserializer.readVersionAndDeserializeList(SimpleVersionedSerializer<T> serializer, DataInputView in)

Constructors in org.apache.flink.streaming.runtime.operators.sink.committables with parameters of type SimpleVersionedSerializer

Constructor and Description
CommittableCollectorSerializer(SimpleVersionedSerializer<CommT> committableSerializer, int subtaskId, int numberOfSubtasks, SinkCommitterMetricGroup metricGroup)

Uses of SimpleVersionedSerializer in org.apache.flink.table.examples.java.connectors

Methods in org.apache.flink.table.examples.java.connectors that return SimpleVersionedSerializer

Modifier and Type	Method and Description
SimpleVersionedSerializer<SocketSource.DummyCheckpoint>	SocketSource.getEnumeratorCheckpointSerializer()
SimpleVersionedSerializer<SocketSource.DummySplit>	SocketSource.getSplitSerializer()