RestartAllFailoverStrategy (Flink : 2.0-preview1 API)

java.lang.Object
- org.apache.flink.runtime.executiongraph.failover.RestartAllFailoverStrategy

All Implemented Interfaces:

FailoverStrategy
```
public class RestartAllFailoverStrategy
extends Object
implements FailoverStrategy
```
A failover strategy that proposes to restart all vertices when a vertex fails.

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class RestartAllFailoverStrategy.Factory
The factory to instantiate RestartAllFailoverStrategy.

Constructor Summary

Constructors
Constructor Description

RestartAllFailoverStrategy(SchedulingTopology topology)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Set<ExecutionVertexID>`	`getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)`	Returns all vertices on any task failure.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - RestartAllFailoverStrategy
```
public RestartAllFailoverStrategy(SchedulingTopology topology)
```
- Method Detail
  - getTasksNeedingRestart
```
public Set<ExecutionVertexID> getTasksNeedingRestart(ExecutionVertexID executionVertexId,
                                                     Throwable cause)
```
    Returns all vertices on any task failure.
    
    Specified by:
    
    getTasksNeedingRestart in interface FailoverStrategy
    
    Parameters:
    
    executionVertexId - ID of the failed task
    
    cause - cause of the failure
    
    Returns:
    
    set of IDs of vertices to restart