Package org.apache.flink.api.common.restartstrategy

Class RestartStrategies.FailureRateRestartStrategyConfiguration

java.lang.Object

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

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

All Implemented Interfaces:

Serializable

Enclosing class:

RestartStrategies

@PublicEvolving
public static final class RestartStrategies.FailureRateRestartStrategyConfiguration
extends RestartStrategies.RestartStrategyConfiguration

Configuration representing a failure rate restart strategy.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
FailureRateRestartStrategyConfiguration(int maxFailureRate, java.time.Duration failureInterval, java.time.Duration delayBetweenAttemptsInterval)
FailureRateRestartStrategyConfiguration(int maxFailureRate, Time failureInterval, Time delayBetweenAttemptsInterval)	Deprecated. Use FailureRateRestartStrategyConfiguration(int, Duration, Duration)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Time	getDelayBetweenAttemptsInterval()	Deprecated. Use getDurationBetweenAttempts()
String	getDescription()	Returns a description which is shown in the web interface.
java.time.Duration	getDurationBetweenAttempts()
Time	getFailureInterval()	Deprecated. Use getFailureIntervalDuration()
java.time.Duration	getFailureIntervalDuration()
int	getMaxFailureRate()
int	hashCode()

Methods inherited from class org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration

toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

FailureRateRestartStrategyConfiguration

@Deprecated
public FailureRateRestartStrategyConfiguration(int maxFailureRate,
                                               Time failureInterval,
                                               Time delayBetweenAttemptsInterval)

Deprecated.

Use FailureRateRestartStrategyConfiguration(int, Duration, Duration)

FailureRateRestartStrategyConfiguration

public FailureRateRestartStrategyConfiguration(int maxFailureRate,
                                               java.time.Duration failureInterval,
                                               java.time.Duration delayBetweenAttemptsInterval)

Method Detail

getMaxFailureRate

public int getMaxFailureRate()

getFailureInterval

@Deprecated
public Time getFailureInterval()

Deprecated.

Use getFailureIntervalDuration()

getFailureIntervalDuration

public java.time.Duration getFailureIntervalDuration()

getDelayBetweenAttemptsInterval

@Deprecated
public Time getDelayBetweenAttemptsInterval()

Deprecated.

Use getDurationBetweenAttempts()

getDurationBetweenAttempts

public java.time.Duration getDurationBetweenAttempts()

getDescription

public String getDescription()

Description copied from class: RestartStrategies.RestartStrategyConfiguration

Returns a description which is shown in the web interface.

Specified by:

getDescription in class RestartStrategies.RestartStrategyConfiguration

Returns:

Description of the restart strategy

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object