org.apache.flink.runtime.executiongraph.failover

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 and Description
static String	FULL_RESTART_STRATEGY_NAME Config name for the RestartAllFailoverStrategy.
static String	PIPELINED_REGION_RESTART_STRATEGY_NAME Config name for the RestartPipelinedRegionFailoverStrategy.

Method Summary

Modifier and Type	Method and Description
static FailoverStrategy.Factory	loadFailoverStrategyFactory(Configuration config) Loads a FailoverStrategy.Factory from the given configuration.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

FULL_RESTART_STRATEGY_NAME

public static final String FULL_RESTART_STRATEGY_NAME

Config name for the RestartAllFailoverStrategy.

See Also:

Constant Field Values

PIPELINED_REGION_RESTART_STRATEGY_NAME

public static final String PIPELINED_REGION_RESTART_STRATEGY_NAME

Config name for the RestartPipelinedRegionFailoverStrategy.

See Also:

Constant Field Values

Method Detail

loadFailoverStrategyFactory

public static FailoverStrategy.Factory loadFailoverStrategyFactory(Configuration config)

Loads a FailoverStrategy.Factory from the given configuration.

Parameters:

config - which specifies the failover strategy factory to load

Returns:

failover strategy factory loaded