Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.savepoint |
Modifier and Type | Method and Description |
---|---|
static <T extends Savepoint> |
Checkpoints.storeCheckpointMetadata(T checkpointMetadata,
DataOutputStream out) |
static <T extends Savepoint> |
Checkpoints.storeCheckpointMetadata(T checkpointMetadata,
OutputStream out) |
Modifier and Type | Method and Description |
---|---|
static Savepoint |
Checkpoints.loadCheckpointMetadata(DataInputStream in,
ClassLoader classLoader) |
Modifier and Type | Interface and Description |
---|---|
interface |
SavepointSerializer<T extends Savepoint>
Serializer for
Savepoint instances. |
Modifier and Type | Class and Description |
---|---|
class |
SavepointV1
Savepoint version 0.
|
class |
SavepointV2
The persistent checkpoint metadata, format version 2.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Savepoint> |
SavepointSerializers.getSerializer(T savepoint)
Returns the
SavepointSerializer for the given savepoint. |
Modifier and Type | Method and Description |
---|---|
static Savepoint |
SavepointV2.convertToOperatorStateSavepointV2(Map<JobVertexID,ExecutionJobVertex> tasks,
Savepoint savepoint)
Deprecated.
Only kept for backwards-compatibility with versions < 1.3. Will be removed in the future.
|
Modifier and Type | Method and Description |
---|---|
static Savepoint |
SavepointV2.convertToOperatorStateSavepointV2(Map<JobVertexID,ExecutionJobVertex> tasks,
Savepoint savepoint)
Deprecated.
Only kept for backwards-compatibility with versions < 1.3. Will be removed in the future.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.