public class SavepointRestoreSettings extends Object implements Serializable
Modifier and Type | Method and Description |
---|---|
boolean |
allowNonRestoredState()
Returns whether non restored state is allowed if the savepoint contains
state that cannot be mapped back to the job.
|
boolean |
equals(Object o) |
static SavepointRestoreSettings |
forPath(String savepointPath) |
static SavepointRestoreSettings |
forPath(String savepointPath,
boolean allowNonRestoredState) |
static SavepointRestoreSettings |
fromConfiguration(Configuration configuration) |
String |
getRestorePath()
Returns the path to the savepoint to restore from.
|
int |
hashCode() |
static SavepointRestoreSettings |
none() |
boolean |
restoreSavepoint()
Returns whether to restore from savepoint.
|
static void |
toConfiguration(SavepointRestoreSettings savepointRestoreSettings,
Configuration configuration) |
String |
toString() |
public boolean restoreSavepoint()
true
if should restore from savepoint.public String getRestorePath()
null
if
should not restore.public boolean allowNonRestoredState()
true
if non restored state is allowed if the savepoint
contains state that cannot be mapped back to the job.public static SavepointRestoreSettings none()
public static SavepointRestoreSettings forPath(String savepointPath)
public static SavepointRestoreSettings forPath(String savepointPath, boolean allowNonRestoredState)
public static void toConfiguration(SavepointRestoreSettings savepointRestoreSettings, Configuration configuration)
public static SavepointRestoreSettings fromConfiguration(Configuration configuration)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.