org.apache.flink.api.common.typeutils

Class GenericTypeSerializerSnapshot<T,S extends TypeSerializer>

java.lang.Object

org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T,S>

Type Parameters:

T - The type to be instantiated.

All Implemented Interfaces:

TypeSerializerSnapshot<T>

Direct Known Subclasses:

CopyableValueSerializer.CopyableValueSerializerSnapshot, ValueSerializer.ValueSerializerSnapshot, WritableSerializer.WritableSerializerSnapshot

@Internal
public abstract class GenericTypeSerializerSnapshot<T,S extends TypeSerializer>
extends Object
implements TypeSerializerSnapshot<T>

Base TypeSerializerSnapshot for serializers for generic types.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GenericTypeSerializerSnapshot()
protected	GenericTypeSerializerSnapshot(Class<T> typeClass)

Method Summary

Modifier and Type	Method and Description
protected abstract TypeSerializer<T>	createSerializer(Class<T> typeClass) Create a serializer that is able to serialize the generic type typeClass.
int	getCurrentVersion() Returns the version of the current snapshot's written binary format.
protected abstract Class<T>	getTypeClass(S serializer) Gets the type class from the corresponding serializer.
void	readSnapshot(int readVersion, DataInputView in, ClassLoader userCodeClassLoader) Reads the serializer snapshot from the provided DataInputView.
TypeSerializerSchemaCompatibility<T>	resolveSchemaCompatibility(TypeSerializer<T> newSerializer) Checks a new serializer's compatibility to read data written by the prior serializer.
TypeSerializer<T>	restoreSerializer() Recreates a serializer instance from this snapshot.
protected abstract Class<?>	serializerClass() Gets the serializer's class.
void	writeSnapshot(DataOutputView out) Writes the serializer snapshot to the provided DataOutputView.

Methods inherited from class java.lang.Object

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

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

readVersionedSnapshot, writeVersionedSnapshot

Constructor Detail

GenericTypeSerializerSnapshot

protected GenericTypeSerializerSnapshot()

GenericTypeSerializerSnapshot

protected GenericTypeSerializerSnapshot(Class<T> typeClass)

Method Detail

createSerializer

protected abstract TypeSerializer<T> createSerializer(Class<T> typeClass)

Create a serializer that is able to serialize the generic type typeClass.

getTypeClass

protected abstract Class<T> getTypeClass(S serializer)

Gets the type class from the corresponding serializer.

serializerClass

protected abstract Class<?> serializerClass()

Gets the serializer's class.

getCurrentVersion

public final int getCurrentVersion()

Description copied from interface: TypeSerializerSnapshot

Returns the version of the current snapshot's written binary format.

Specified by:

getCurrentVersion in interface TypeSerializerSnapshot<T>

Returns:

the version of the current snapshot's written binary format.

writeSnapshot

public final void writeSnapshot(DataOutputView out)
                         throws IOException

Description copied from interface: TypeSerializerSnapshot

Writes the serializer snapshot to the provided DataOutputView. The current version of the written serializer snapshot's binary format is specified by the TypeSerializerSnapshot.getCurrentVersion() method.

Specified by:

writeSnapshot in interface TypeSerializerSnapshot<T>

Parameters:

out - the DataOutputView to write the snapshot to.

Throws:

IOException - Thrown if the snapshot data could not be written.

See Also:

TypeSerializerSnapshot.writeVersionedSnapshot(DataOutputView, TypeSerializerSnapshot)

readSnapshot

public final void readSnapshot(int readVersion,
                               DataInputView in,
                               ClassLoader userCodeClassLoader)
                        throws IOException

Description copied from interface: TypeSerializerSnapshot

Reads the serializer snapshot from the provided DataInputView. The version of the binary format that the serializer snapshot was written with is provided. This version can be used to determine how the serializer snapshot should be read.

Specified by:

readSnapshot in interface TypeSerializerSnapshot<T>

Parameters:

readVersion - version of the serializer snapshot's written binary format

in - the DataInputView to read the snapshot from.

userCodeClassLoader - the user code classloader

Throws:

IOException - Thrown if the snapshot data could be read or parsed.

See Also:

TypeSerializerSnapshot.readVersionedSnapshot(DataInputView, ClassLoader)

restoreSerializer

public final TypeSerializer<T> restoreSerializer()

Description copied from interface: TypeSerializerSnapshot

Recreates a serializer instance from this snapshot. The returned serializer can be safely used to read data written by the prior serializer (i.e., the serializer that created this snapshot).

Specified by:

restoreSerializer in interface TypeSerializerSnapshot<T>

Returns:

a serializer instance restored from this serializer snapshot.

resolveSchemaCompatibility

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

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>

Parameters:

newSerializer - the new serializer to check.

Returns:

the serializer compatibility result.