Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.metadata | |
org.apache.flink.state.api.output | |
org.apache.flink.state.api.runtime |
Modifier and Type | Method and Description |
---|---|
static CheckpointMetadata |
Checkpoints.loadCheckpointMetadata(DataInputStream in,
ClassLoader classLoader,
String externalPointer) |
Modifier and Type | Method and Description |
---|---|
static void |
Checkpoints.storeCheckpointMetadata(CheckpointMetadata checkpointMetadata,
DataOutputStream out) |
static void |
Checkpoints.storeCheckpointMetadata(CheckpointMetadata checkpointMetadata,
OutputStream out) |
Modifier and Type | Method and Description |
---|---|
CheckpointMetadata |
MetadataV1Serializer.deserialize(DataInputStream dis,
ClassLoader cl,
String externalPointer) |
CheckpointMetadata |
MetadataV3Serializer.deserialize(DataInputStream dis,
ClassLoader classLoader,
String externalPointer) |
CheckpointMetadata |
MetadataV2Serializer.deserialize(DataInputStream dis,
ClassLoader classLoader,
String externalPointer) |
CheckpointMetadata |
MetadataSerializer.deserialize(DataInputStream dis,
ClassLoader userCodeClassLoader,
String externalPointer)
Deserializes a savepoint from an input stream.
|
protected CheckpointMetadata |
MetadataV2V3SerializerBase.deserializeMetadata(DataInputStream dis,
String externalPointer) |
Modifier and Type | Method and Description |
---|---|
static void |
MetadataV3Serializer.serialize(CheckpointMetadata checkpointMetadata,
DataOutputStream dos) |
protected void |
MetadataV2V3SerializerBase.serializeMetadata(CheckpointMetadata checkpointMetadata,
DataOutputStream dos) |
Modifier and Type | Method and Description |
---|---|
void |
SavepointOutputFormat.writeRecord(CheckpointMetadata metadata) |
Modifier and Type | Method and Description |
---|---|
void |
MergeOperatorStates.reduce(Iterable<OperatorState> values,
Collector<CheckpointMetadata> out) |
Modifier and Type | Method and 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.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.