Package org.apache.flink.runtime.checkpoint.metadata

Class MetadataV4Serializer

java.lang.Object

org.apache.flink.runtime.checkpoint.metadata.MetadataV4Serializer

All Implemented Interfaces:

org.apache.flink.core.io.Versioned, MetadataSerializer

@Internal
public class MetadataV4Serializer
extends Object
implements MetadataSerializer

V4 serializer that adds CheckpointProperties serialization.

Field Summary

Fields

Modifier and Type	Field	Description
static MetadataSerializer	INSTANCE
static int	VERSION

Constructor Summary

Constructors

Constructor	Description
MetadataV4Serializer()

Method Summary

Modifier and Type	Method	Description
CheckpointMetadata	deserialize(DataInputStream dis, ClassLoader userCodeClassLoader, String externalPointer)	Deserializes a savepoint from an input stream.
int	getVersion()
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

INSTANCE

public static final MetadataSerializer INSTANCE

VERSION

public static final int VERSION

See Also:

Constant Field Values

Constructor Detail

MetadataV4Serializer

public MetadataV4Serializer()

Method Detail

getVersion

public int getVersion()

Specified by:

getVersion in interface org.apache.flink.core.io.Versioned

deserialize

public CheckpointMetadata deserialize(DataInputStream dis,
                                      ClassLoader userCodeClassLoader,
                                      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

userCodeClassLoader - 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