Class RestartAllFailoverStrategy.Factory
- java.lang.Object
-
- org.apache.flink.runtime.executiongraph.failover.RestartAllFailoverStrategy.Factory
-
- All Implemented Interfaces:
FailoverStrategy.Factory
- Enclosing class:
- RestartAllFailoverStrategy
public static class RestartAllFailoverStrategy.Factory extends Object implements FailoverStrategy.Factory
The factory to instantiateRestartAllFailoverStrategy
.
-
-
Constructor Summary
Constructors Constructor Description Factory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FailoverStrategy
create(SchedulingTopology topology, ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
Instantiates theFailoverStrategy
.
-
-
-
Method Detail
-
create
public FailoverStrategy create(SchedulingTopology topology, ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
Description copied from interface:FailoverStrategy.Factory
Instantiates theFailoverStrategy
.- Specified by:
create
in interfaceFailoverStrategy.Factory
- Parameters:
topology
- of the graph to failoverresultPartitionAvailabilityChecker
- to check whether a result partition is available- Returns:
- The instantiated failover strategy.
-
-