Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Method and Description |
---|---|
static CheckpointProperties |
CheckpointProperties.forExternalizedCheckpoint(boolean deleteOnCancellation)
Creates the checkpoint properties for an external checkpoint.
|
static CheckpointProperties |
CheckpointProperties.forStandardCheckpoint()
Creates the checkpoint properties for a regular checkpoint.
|
static CheckpointProperties |
CheckpointProperties.forStandardSavepoint()
Creates the checkpoint properties for a (manually triggered) savepoint.
|
CheckpointProperties |
RestoredCheckpointStats.getProperties()
Returns the properties of the restored checkpoint.
|
CheckpointProperties |
CompletedCheckpoint.getProperties() |
CheckpointProperties |
AbstractCheckpointStats.getProperties()
Returns the properties of this checkpoint.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
CheckpointProperties.isSavepoint(CheckpointProperties props)
Returns whether the checkpoint properties describe a standard savepoint.
|
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<JobVertexID,TaskState> taskStates,
CheckpointProperties props,
String externalPath) |
PendingCheckpoint(JobID jobId,
long checkpointId,
long checkpointTimestamp,
Map<ExecutionAttemptID,ExecutionVertex> verticesToConfirm,
CheckpointProperties props,
String targetDirectory,
Executor executor) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.