public class CheckpointOptions extends Object implements Serializable
The CheckpointProperties
are related and cover properties that
are only relevant at the CheckpointCoordinator
. These options are
relevant at the StatefulTask
instances running on task managers.
Modifier and Type | Class and Description |
---|---|
static class |
CheckpointOptions.CheckpointType
The type of checkpoint to perform.
|
Modifier and Type | Method and Description |
---|---|
static CheckpointOptions |
forCheckpoint() |
static CheckpointOptions |
forSavepoint(String targetDirectory) |
CheckpointOptions.CheckpointType |
getCheckpointType()
Returns the type of checkpoint to perform.
|
String |
getTargetLocation()
Returns a custom target location or
null if none
was specified. |
String |
toString() |
@Nonnull public CheckpointOptions.CheckpointType getCheckpointType()
@Nullable public String getTargetLocation()
null
if none
was specified.null
.public static CheckpointOptions forCheckpoint()
public static CheckpointOptions forSavepoint(String targetDirectory)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.