org.apache.flink.api.java.typeutils.runtime

Class ValueSerializer.ValueSerializerConfigSnapshot<T extends Value>

java.lang.Object

org.apache.flink.core.io.VersionedIOReadableWritable

org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot<T>

org.apache.flink.api.common.typeutils.GenericTypeSerializerConfigSnapshot<T>

org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot<T>

org.apache.flink.api.java.typeutils.runtime.ValueSerializer.ValueSerializerConfigSnapshot<T>

All Implemented Interfaces:

TypeSerializerSnapshot<T>, IOReadableWritable, Versioned

Enclosing class:

ValueSerializer<T extends Value>

Deprecated.

@Deprecated
public static class ValueSerializer.ValueSerializerConfigSnapshot<T extends Value>
extends KryoRegistrationSerializerConfigSnapshot<T>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot

KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass<RC>, KryoRegistrationSerializerConfigSnapshot.DummyRegisteredClass

Nested classes/interfaces inherited from class org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot

TypeSerializerConfigSnapshot.SelfResolvingTypeSerializer<E>

Field Summary

Fields

Modifier and Type	Field and Description
static long	serialVersionUID Deprecated.

Constructor Summary

Constructors

Constructor and Description
ValueSerializerConfigSnapshot() Deprecated. This empty nullary constructor is required for deserializing the configuration.
ValueSerializerConfigSnapshot(Class<T> valueTypeClass) Deprecated.

Method Summary

Modifier and Type	Method and Description
int	getVersion() Deprecated. Returns the version number of the object.
TypeSerializerSchemaCompatibility<T>	resolveSchemaCompatibility(TypeSerializer<T> newSerializer) Deprecated. Checks a new serializer's compatibility to read data written by the prior serializer.

Methods inherited from class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot

equals, getKryoRegistrations, hashCode, read, write

Methods inherited from class org.apache.flink.api.common.typeutils.GenericTypeSerializerConfigSnapshot

getTypeClass

Methods inherited from class org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot

getCurrentVersion, getUserCodeClassLoader, readSnapshot, restoreSerializer, setPriorSerializer, setUserCodeClassLoader, writeSnapshot

Methods inherited from class org.apache.flink.core.io.VersionedIOReadableWritable

getCompatibleVersions, getReadVersion

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot

readVersionedSnapshot, writeVersionedSnapshot

Field Detail

serialVersionUID

public static final long serialVersionUID

Deprecated.

See Also:

Constant Field Values

Constructor Detail

ValueSerializerConfigSnapshot

public ValueSerializerConfigSnapshot()

Deprecated.

This empty nullary constructor is required for deserializing the configuration.

ValueSerializerConfigSnapshot

public ValueSerializerConfigSnapshot(Class<T> valueTypeClass)

Deprecated.

Method Detail

getVersion

public int getVersion()

Deprecated.

Description copied from interface: Versioned

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

resolveSchemaCompatibility

public TypeSerializerSchemaCompatibility<T> resolveSchemaCompatibility(TypeSerializer<T> newSerializer)

Deprecated.

Description copied from interface: TypeSerializerSnapshot

Checks a new serializer's compatibility to read data written by the prior serializer.

When a checkpoint/savepoint is restored, this method checks whether the serialization format of the data in the checkpoint/savepoint is compatible for the format of the serializer used by the program that restores the checkpoint/savepoint. The outcome can be that the serialization format is compatible, that the program's serializer needs to reconfigure itself (meaning to incorporate some information from the TypeSerializerSnapshot to be compatible), that the format is outright incompatible, or that a migration needed. In the latter case, the TypeSerializerSnapshot produces a serializer to deserialize the data, and the restoring program's serializer re-serializes the data, thus converting the format during the restore operation.

Specified by:

resolveSchemaCompatibility in interface TypeSerializerSnapshot<T extends Value>

Overrides:

resolveSchemaCompatibility in class TypeSerializerConfigSnapshot<T extends Value>

Parameters:

newSerializer - the new serializer to check.

Returns:

the serializer compatibility result.