Interface MetadataSerializer
-
- All Superinterfaces:
Versioned
- All Known Implementing Classes:
MetadataV1Serializer
,MetadataV2Serializer
,MetadataV3Serializer
,MetadataV4Serializer
,MetadataV5Serializer
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
All Methods Instance Methods Abstract Methods Modifier and Type Method 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 fromuserCodeClassLoader
- the user code class loaderexternalPointer
- 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
-
-