@Internal public class MetadataV2Serializer extends MetadataV2V3SerializerBase implements MetadataSerializer
See MetadataV2V3SerializerBase
for a description of the format layout.
MetadataV2V3SerializerBase.DeserializationContext
Modifier and Type | Field and Description |
---|---|
static MetadataV2Serializer |
INSTANCE
The singleton instance of the serializer.
|
static int |
VERSION
The metadata format version.
|
Modifier and Type | Method and Description |
---|---|
CheckpointMetadata |
deserialize(DataInputStream dis,
ClassLoader classLoader,
String externalPointer)
Deserializes a savepoint from an input stream.
|
protected OperatorState |
deserializeOperatorState(DataInputStream dis,
MetadataV2V3SerializerBase.DeserializationContext context) |
protected OperatorSubtaskState |
deserializeSubtaskState(DataInputStream dis,
MetadataV2V3SerializerBase.DeserializationContext context) |
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.
|
protected void |
serializeOperatorState(OperatorState operatorState,
DataOutputStream dos) |
protected void |
serializeSubtaskState(OperatorSubtaskState subtaskState,
DataOutputStream dos) |
deserializeInputChannelStateHandle, deserializeMasterState, deserializeMetadata, deserializeResultSubpartitionStateHandle, serializeInputChannelStateHandle, serializeMasterState, serializeMetadata, serializeResultSubpartitionStateHandle
public static final int VERSION
public static final MetadataV2Serializer INSTANCE
public int getVersion()
Versioned
getVersion
in interface Versioned
public CheckpointMetadata deserialize(DataInputStream dis, ClassLoader classLoader, String externalPointer) throws IOException
MetadataSerializer
deserialize
in interface MetadataSerializer
dis
- Input stream to deserialize savepoint fromclassLoader
- the user code class loaderexternalPointer
- the external pointer of the given checkpointIOException
- Serialization failures are forwardedpublic void serialize(CheckpointMetadata checkpointMetadata, DataOutputStream dos) throws IOException
MetadataSerializer
serialize
in interface MetadataSerializer
IOException
- Serialization failures are forwardedprotected void serializeOperatorState(OperatorState operatorState, DataOutputStream dos) throws IOException
serializeOperatorState
in class MetadataV2V3SerializerBase
IOException
protected OperatorState deserializeOperatorState(DataInputStream dis, @Nullable MetadataV2V3SerializerBase.DeserializationContext context) throws IOException
deserializeOperatorState
in class MetadataV2V3SerializerBase
IOException
protected void serializeSubtaskState(OperatorSubtaskState subtaskState, DataOutputStream dos) throws IOException
serializeSubtaskState
in class MetadataV2V3SerializerBase
IOException
protected OperatorSubtaskState deserializeSubtaskState(DataInputStream dis, @Nullable MetadataV2V3SerializerBase.DeserializationContext context) throws IOException
deserializeSubtaskState
in class MetadataV2V3SerializerBase
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.