public interface FailoverStrategy
Modifier and Type | Interface and Description |
---|---|
static interface |
FailoverStrategy.Factory
The factory to instantiate
FailoverStrategy . |
Modifier and Type | Method and Description |
---|---|
Set<ExecutionVertexID> |
getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
Set<ExecutionVertexID> getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)
executionVertexId
- ID of the failed taskcause
- cause of the failureCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.