org.apache.flink.core.io

Interface Versioned

All Known Subinterfaces:

MetadataSerializer, SimpleVersionedSerializer<E>

All Known Implementing Classes:

AsyncSinkWriterStateSerializer, CommittableCollectorSerializer, CommittableMessageSerializer, CompactorRequestSerializer, ContinuousHivePendingSplitsCheckpointSerializer, FileSinkCommittableSerializer, FileSourceSplitSerializer, FileWriterBucketStateSerializer, FromElementsSplitSerializer, HiveSourceSplitSerializer, HiveTablePartitionSerializer, HybridSourceEnumeratorStateSerializer, HybridSourceSplitSerializer, InternalTimerServiceSerializationProxy, KeyedBackendSerializationProxy, MetadataV1Serializer, MetadataV2Serializer, MetadataV3Serializer, MetadataV4Serializer, NoOpEnumStateSerializer, OperatorBackendSerializationProxy, OSSRecoverableSerializer, OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverableSerializer, OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverableSerializer, PendingSplitsCheckpointSerializer, PostVersionedIOReadableWritable, SimpleVersionedStringSerializer, VersionedIOReadableWritable

@PublicEvolving
public interface Versioned

This interface is implemented by classes that provide a version number. Versions numbers can be used to differentiate between evolving classes.

Method Summary

Modifier and Type	Method and Description
int	getVersion() Returns the version number of the object.

Method Detail

getVersion

int getVersion()

Returns the version number of the object. Versions numbers can be used to differentiate evolving classes.