org.apache.flink.api.common.restartstrategy

Class RestartStrategies

java.lang.Object

org.apache.flink.api.common.restartstrategy.RestartStrategies

@PublicEvolving
public class RestartStrategies
extends Object

This class defines methods to generate RestartStrategyConfigurations. These configurations are used to create RestartStrategies at runtime. The RestartStrategyConfigurations are used to decouple the core module from the runtime module.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RestartStrategies.FailureRateRestartStrategyConfiguration
static class	RestartStrategies.FallbackRestartStrategyConfiguration Restart strategy configuration that could be used by jobs to use cluster level restart strategy.
static class	RestartStrategies.FixedDelayRestartStrategyConfiguration
static class	RestartStrategies.NoRestartStrategyConfiguration
static class	RestartStrategies.RestartStrategyConfiguration

Constructor Summary

Constructors

Constructor and Description
RestartStrategies()

Method Summary

Modifier and Type	Method and Description
static RestartStrategies.FailureRateRestartStrategyConfiguration	failureRateRestart(int failureRate, Time failureInterval, Time delayInterval) Generates a FailureRateRestartStrategyConfiguration.
static RestartStrategies.RestartStrategyConfiguration	fallBackRestart()
static RestartStrategies.RestartStrategyConfiguration	fixedDelayRestart(int restartAttempts, long delayBetweenAttempts) Generates a FixedDelayRestartStrategyConfiguration.
static RestartStrategies.RestartStrategyConfiguration	fixedDelayRestart(int restartAttempts, Time delayInterval) Generates a FixedDelayRestartStrategyConfiguration.
static RestartStrategies.RestartStrategyConfiguration	noRestart() Generates NoRestartStrategyConfiguration

Methods inherited from class java.lang.Object

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

Constructor Detail

RestartStrategies

public RestartStrategies()

Method Detail

noRestart

public static RestartStrategies.RestartStrategyConfiguration noRestart()

Generates NoRestartStrategyConfiguration

Returns:

NoRestartStrategyConfiguration

fallBackRestart

public static RestartStrategies.RestartStrategyConfiguration fallBackRestart()

fixedDelayRestart

public static RestartStrategies.RestartStrategyConfiguration fixedDelayRestart(int restartAttempts,
                                                                               long delayBetweenAttempts)

Generates a FixedDelayRestartStrategyConfiguration.

Parameters:

restartAttempts - Number of restart attempts for the FixedDelayRestartStrategy

delayBetweenAttempts - Delay in-between restart attempts for the FixedDelayRestartStrategy

Returns:

FixedDelayRestartStrategy

fixedDelayRestart

public static RestartStrategies.RestartStrategyConfiguration fixedDelayRestart(int restartAttempts,
                                                                               Time delayInterval)

Generates a FixedDelayRestartStrategyConfiguration.

Parameters:

restartAttempts - Number of restart attempts for the FixedDelayRestartStrategy

delayInterval - Delay in-between restart attempts for the FixedDelayRestartStrategy

Returns:

FixedDelayRestartStrategy

failureRateRestart

public static RestartStrategies.FailureRateRestartStrategyConfiguration failureRateRestart(int failureRate,
                                                                                           Time failureInterval,
                                                                                           Time delayInterval)

Generates a FailureRateRestartStrategyConfiguration.

Parameters:

failureRate - Maximum number of restarts in given interval failureInterval before failing a job

failureInterval - Time interval for failures

delayInterval - Delay in-between restart attempts