Class FailoverStrategyFactoryLoader
- java.lang.Object
-
- org.apache.flink.runtime.executiongraph.failover.FailoverStrategyFactoryLoader
-
public final class FailoverStrategyFactoryLoader extends Object
A utility class to load NG failover strategy factories from the configuration.
-
-
Field Summary
Fields Modifier and Type Field Description static String
FULL_RESTART_STRATEGY_NAME
Config name for theRestartAllFailoverStrategy
.static String
PIPELINED_REGION_RESTART_STRATEGY_NAME
Config name for theRestartPipelinedRegionFailoverStrategy
.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static FailoverStrategy.Factory
loadFailoverStrategyFactory(Configuration config)
Loads aFailoverStrategy.Factory
from the given configuration.
-
-
-
Field Detail
-
FULL_RESTART_STRATEGY_NAME
public static final String FULL_RESTART_STRATEGY_NAME
Config name for theRestartAllFailoverStrategy
.- See Also:
- Constant Field Values
-
PIPELINED_REGION_RESTART_STRATEGY_NAME
public static final String PIPELINED_REGION_RESTART_STRATEGY_NAME
Config name for theRestartPipelinedRegionFailoverStrategy
.- See Also:
- Constant Field Values
-
-
Method Detail
-
loadFailoverStrategyFactory
public static FailoverStrategy.Factory loadFailoverStrategyFactory(Configuration config)
Loads aFailoverStrategy.Factory
from the given configuration.- Parameters:
config
- which specifies the failover strategy factory to load- Returns:
- failover strategy factory loaded
-
-