public class RestartAllStrategy extends Object implements FailoverStrategy
Modifier and Type | Class and Description |
---|---|
static class |
RestartAllStrategy.Factory
The factory to instantiate
RestartAllStrategy . |
Constructor and Description |
---|
RestartAllStrategy(FailoverTopology<?,?> topology) |
Modifier and Type | Method and Description |
---|---|
Set<ExecutionVertexID> |
getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns all vertices on any task failure.
|
public RestartAllStrategy(FailoverTopology<?,?> topology)
public Set<ExecutionVertexID> getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)
getTasksNeedingRestart
in interface FailoverStrategy
executionVertexId
- ID of the failed taskcause
- cause of the failureCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.