public class CheckpointProperties extends Object implements Serializable
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
static CheckpointProperties |
forExternalizedCheckpoint(boolean deleteOnCancellation)
Creates the checkpoint properties for an external checkpoint.
|
static CheckpointProperties |
forStandardCheckpoint()
Creates the checkpoint properties for a regular checkpoint.
|
static CheckpointProperties |
forStandardSavepoint()
Creates the checkpoint properties for a (manually triggered) savepoint.
|
int |
hashCode() |
boolean |
isSavepoint()
Returns whether the checkpoint properties describe a standard savepoint.
|
String |
toString() |
public boolean isSavepoint()
true
if the properties describe a savepoint, false
otherwise.public static CheckpointProperties forStandardSavepoint()
Savepoints are forced and persisted externally. They have to be garbage collected manually.
public static CheckpointProperties forStandardCheckpoint()
Regular checkpoints are not forced and not persisted externally. They are garbage collected automatically.
public static CheckpointProperties forExternalizedCheckpoint(boolean deleteOnCancellation)
External checkpoints are not forced, but persisted externally. They
are garbage collected automatically, except when the owning job
terminates in state JobStatus.FAILED
. The user is required to
configure the clean up behaviour on job cancellation.
deleteOnCancellation
- Flag indicating whether to discard on cancellation.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.