public class FailureHandlingResult extends Object
Modifier and Type | Method and Description |
---|---|
boolean |
canRestart()
Returns whether the restarting can be conducted.
|
Throwable |
getError()
Returns reason why the restarting cannot be conducted.
|
long |
getRestartDelayMS()
Returns the delay before the restarting.
|
Set<ExecutionVertexID> |
getVerticesToRestart()
Returns the tasks to restart.
|
static FailureHandlingResult |
restartable(Set<ExecutionVertexID> verticesToRestart,
long restartDelayMS)
Creates a result of a set of tasks to restart to recover from the failure.
|
static FailureHandlingResult |
unrecoverable(Throwable error)
Creates a result that the failure is not recoverable and no restarting should be conducted.
|
public Set<ExecutionVertexID> getVerticesToRestart()
public long getRestartDelayMS()
public Throwable getError()
public boolean canRestart()
public static FailureHandlingResult restartable(Set<ExecutionVertexID> verticesToRestart, long restartDelayMS)
verticesToRestart
- containing task vertices to restart to recover from the failurerestartDelayMS
- indicate a delay before conducting the restartpublic static FailureHandlingResult unrecoverable(Throwable error)
error
- reason why the failure is not recoverableCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.