class RestartAllFailoverStrategy implements FailoverStrategy {

	@Override
	public Set<ExecutionVertexID> getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause) {
		return IterableUtils.toStream(topology.getVertices())
			.map(SchedulingExecutionVertex::getId)
			.collect(Collectors.toSet());
	}

	public  RestartAllFailoverStrategy(final SchedulingTopology topology);

}