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,
DataOutputStream out,
MetadataSerializer serializer) |
static void |
Checkpoints.storeCheckpointMetadata(CheckpointMetadata checkpointMetadata,
OutputStream out) |
Modifier and Type | Method and Description |
---|---|
CheckpointMetadata |
MetadataV3Serializer.deserialize(DataInputStream dis,
ClassLoader classLoader,
String externalPointer) |
CheckpointMetadata |
MetadataV1Serializer.deserialize(DataInputStream dis,
ClassLoader cl,
String externalPointer) |
CheckpointMetadata |
MetadataSerializer.deserialize(DataInputStream dis,
ClassLoader userCodeClassLoader,
String externalPointer)
Deserializes a savepoint from an input stream.
|
CheckpointMetadata |
MetadataV4Serializer.deserialize(DataInputStream dis,
ClassLoader userCodeClassLoader,
String externalPointer) |
CheckpointMetadata |
MetadataV2Serializer.deserialize(DataInputStream dis,
ClassLoader classLoader,
String externalPointer) |
protected CheckpointMetadata |
MetadataV2V3SerializerBase.deserializeMetadata(DataInputStream dis,
String externalPointer) |
CheckpointMetadata |
CheckpointMetadata.withProperties(CheckpointProperties properties) |
Modifier and Type | Method and Description |
---|---|
void |
MetadataV3Serializer.serialize(CheckpointMetadata checkpointMetadata,
DataOutputStream dos) |
void |
MetadataV1Serializer.serialize(CheckpointMetadata checkpointMetadata,
DataOutputStream dos) |
void |
MetadataSerializer.serialize(CheckpointMetadata checkpointMetadata,
DataOutputStream dos)
Serializes a savepoint or checkpoint metadata to an output stream.
|
void |
MetadataV4Serializer.serialize(CheckpointMetadata checkpointMetadata,
DataOutputStream dos) |
void |
MetadataV2Serializer.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.
|
Modifier and Type | Method and Description |
---|---|
static CheckpointMetadata |
TestUtils.loadCheckpointMetadata(String savepointPath) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.