org.apache.flink.runtime.checkpoint.metadata

Interface MetadataSerializer

All Superinterfaces:

Versioned

All Known Implementing Classes:

MetadataV1Serializer, MetadataV2Serializer, MetadataV3Serializer, MetadataV4Serializer

public interface MetadataSerializer
extends Versioned

Deserializer for checkpoint metadata. Different deserializers exist to deserialize from different format versions.

Version-specific serializers are accessed via the MetadataSerializers helper.

Method Summary

Modifier and Type	Method and Description
CheckpointMetadata	deserialize(DataInputStream dis, ClassLoader userCodeClassLoader, String externalPointer) Deserializes a savepoint from an input stream.
void	serialize(CheckpointMetadata checkpointMetadata, DataOutputStream dos) Serializes a savepoint or checkpoint metadata to an output stream.

Methods inherited from interface org.apache.flink.core.io.Versioned

getVersion

Method Detail

deserialize

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

Deserializes a savepoint from an input stream.

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

void serialize(CheckpointMetadata checkpointMetadata,
               DataOutputStream dos)
        throws IOException

Serializes a savepoint or checkpoint metadata to an output stream.

Throws:

IOException - Serialization failures are forwarded