org.apache.flink.runtime.checkpoint.metadata

Class MetadataV1Serializer

java.lang.Object

org.apache.flink.runtime.checkpoint.metadata.MetadataV1Serializer

All Implemented Interfaces:

Versioned, MetadataSerializer

@Internal
public class MetadataV1Serializer
extends Object
implements MetadataSerializer

Deserializer for checkpoints written in format 1 (Flink 1.2.x format). This class is only retained to give a better error message: Rather than getting a "unknown version", the user gets a "version no longer supported".

Field Summary

Fields

Modifier and Type	Field and Description
static MetadataV1Serializer	INSTANCE
static int	VERSION The savepoint version.

Method Summary

Modifier and Type	Method and Description
CheckpointMetadata	deserialize(DataInputStream dis, ClassLoader cl, String externalPointer) Deserializes a savepoint from an input stream.
int	getVersion() Returns the version number of the object.
void	serialize(CheckpointMetadata checkpointMetadata, DataOutputStream dos) Serializes a savepoint or checkpoint metadata to an output stream.

Methods inherited from class java.lang.Object

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

Field Detail

VERSION

public static final int VERSION

The savepoint version.

See Also:

Constant Field Values

INSTANCE

public static final MetadataV1Serializer INSTANCE

Method Detail

getVersion

public int getVersion()

Description copied from interface: Versioned

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

Specified by:

getVersion in interface Versioned

deserialize

public CheckpointMetadata deserialize(DataInputStream dis,
                                      ClassLoader cl,
                                      String externalPointer)
                               throws IOException

Description copied from interface: MetadataSerializer

Deserializes a savepoint from an input stream.

Specified by:

deserialize in interface MetadataSerializer

Parameters:

dis - Input stream to deserialize savepoint from

cl - the user code class loader

externalPointer - the external pointer of the given checkpoint

Returns:

The deserialized savepoint

Throws:

IOException - Serialization failures are forwarded

serialize

public void serialize(CheckpointMetadata checkpointMetadata,
                      DataOutputStream dos)
               throws IOException

Description copied from interface: MetadataSerializer

Serializes a savepoint or checkpoint metadata to an output stream.

Specified by:

serialize in interface MetadataSerializer

Throws:

IOException - Serialization failures are forwarded