Package org.apache.flink.runtime.executiongraph.failover

Interface Summary

Interface	Description
FailoverStrategy.Factory	This factory is a necessary indirection when creating the FailoverStrategy to that we can have both the FailoverStrategy final in the ExecutionGraph, and the ExecutionGraph final in the FailOverStrategy.

Class Summary

Class	Description
AdaptedRestartPipelinedRegionStrategyNG	This failover strategy uses flip1.RestartPipelinedRegionStrategy to make task failover decisions.
AdaptedRestartPipelinedRegionStrategyNG.Factory	Factory that instantiates the AdaptedRestartPipelinedRegionStrategyNG.
FailoverRegion	FailoverRegion manages the failover of a minimal pipeline connected sub graph.
FailoverStrategy	A FailoverStrategy describes how the job computation recovers from task failures.
FailoverStrategyLoader	A utility class to load failover strategies from the configuration.
RestartAllStrategy	Simple failover strategy that triggers a restart of all tasks in the execution graph, via ExecutionGraph.failGlobal(Throwable).
RestartAllStrategy.Factory	Factory that instantiates the RestartAllStrategy.
RestartIndividualStrategy	Simple failover strategy that restarts each task individually.
RestartIndividualStrategy.Factory	Factory that instantiates the RestartAllStrategy.
RestartPipelinedRegionStrategy	A failover strategy that restarts regions of the ExecutionGraph with state.
RestartPipelinedRegionStrategy.Factory	Factory that instantiates the RestartPipelinedRegionStrategy.