Uses of Class
org.apache.flink.runtime.checkpoint.metadata.CheckpointMetadata
-
-
Uses of CheckpointMetadata in org.apache.flink.runtime.checkpoint
Methods in org.apache.flink.runtime.checkpoint that return CheckpointMetadata Modifier and Type Method Description static CheckpointMetadata
Checkpoints. loadCheckpointMetadata(DataInputStream in, ClassLoader classLoader, String externalPointer)
Methods in org.apache.flink.runtime.checkpoint with parameters of type CheckpointMetadata Modifier and Type Method Description static void
Checkpoints. storeCheckpointMetadata(CheckpointMetadata checkpointMetadata, DataOutputStream out)
static void
Checkpoints. storeCheckpointMetadata(CheckpointMetadata checkpointMetadata, DataOutputStream out, MetadataSerializer serializer)
static void
Checkpoints. storeCheckpointMetadata(CheckpointMetadata checkpointMetadata, OutputStream out)
-
Uses of CheckpointMetadata in org.apache.flink.runtime.checkpoint.metadata
Methods in org.apache.flink.runtime.checkpoint.metadata that return CheckpointMetadata Modifier and Type Method Description CheckpointMetadata
MetadataSerializer. deserialize(DataInputStream dis, ClassLoader userCodeClassLoader, String externalPointer)
Deserializes a savepoint from an input stream.CheckpointMetadata
MetadataV1Serializer. deserialize(DataInputStream dis, ClassLoader cl, String externalPointer)
CheckpointMetadata
MetadataV2Serializer. deserialize(DataInputStream dis, ClassLoader classLoader, String externalPointer)
CheckpointMetadata
MetadataV3Serializer. deserialize(DataInputStream dis, ClassLoader classLoader, String externalPointer)
CheckpointMetadata
MetadataV4Serializer. deserialize(DataInputStream dis, ClassLoader userCodeClassLoader, String externalPointer)
protected CheckpointMetadata
MetadataV2V3SerializerBase. deserializeMetadata(DataInputStream dis, String externalPointer)
CheckpointMetadata
CheckpointMetadata. withProperties(CheckpointProperties properties)
Methods in org.apache.flink.runtime.checkpoint.metadata with parameters of type CheckpointMetadata Modifier and Type Method Description void
MetadataSerializer. serialize(CheckpointMetadata checkpointMetadata, DataOutputStream dos)
Serializes a savepoint or checkpoint metadata to an output stream.void
MetadataV1Serializer. serialize(CheckpointMetadata checkpointMetadata, DataOutputStream dos)
void
MetadataV2Serializer. serialize(CheckpointMetadata checkpointMetadata, DataOutputStream dos)
void
MetadataV3Serializer. serialize(CheckpointMetadata checkpointMetadata, DataOutputStream dos)
void
MetadataV4Serializer. serialize(CheckpointMetadata checkpointMetadata, DataOutputStream dos)
protected void
MetadataV2V3SerializerBase. serializeMetadata(CheckpointMetadata checkpointMetadata, DataOutputStream dos)
-
Uses of CheckpointMetadata in org.apache.flink.state.api.output
Methods in org.apache.flink.state.api.output with parameters of type CheckpointMetadata Modifier and Type Method Description void
SavepointOutputFormat. writeRecord(CheckpointMetadata metadata)
Method parameters in org.apache.flink.state.api.output with type arguments of type CheckpointMetadata Modifier and Type Method Description void
MergeOperatorStates. reduce(Iterable<OperatorState> values, Collector<CheckpointMetadata> out)
-
Uses of CheckpointMetadata in org.apache.flink.state.api.runtime
Methods in org.apache.flink.state.api.runtime that return CheckpointMetadata Modifier and Type Method Description static CheckpointMetadata
SavepointLoader. loadSavepointMetadata(String savepointPath)
Takes the given string (representing a pointer to a checkpoint) and resolves it to a file status for the checkpoint's metadata file. -
Uses of CheckpointMetadata in org.apache.flink.test.util
Methods in org.apache.flink.test.util that return CheckpointMetadata Modifier and Type Method Description static CheckpointMetadata
TestUtils. loadCheckpointMetadata(String savepointPath)
-