org.apache.flink.runtime.executiongraph.failover

Class FixedDelayRestartBackoffTimeStrategy.FixedDelayRestartBackoffTimeStrategyFactory

java.lang.Object

org.apache.flink.runtime.executiongraph.failover.FixedDelayRestartBackoffTimeStrategy.FixedDelayRestartBackoffTimeStrategyFactory

All Implemented Interfaces:

RestartBackoffTimeStrategy.Factory

Enclosing class:

FixedDelayRestartBackoffTimeStrategy

public static class FixedDelayRestartBackoffTimeStrategy.FixedDelayRestartBackoffTimeStrategyFactory
extends Object
implements RestartBackoffTimeStrategy.Factory

The factory for creating FixedDelayRestartBackoffTimeStrategy.

Constructor Summary

Constructors

Constructor and Description
FixedDelayRestartBackoffTimeStrategyFactory(int maxNumberRestartAttempts, long backoffTimeMS)

Method Summary

Modifier and Type	Method and Description
RestartBackoffTimeStrategy	create() Instantiates the RestartBackoffTimeStrategy.

Methods inherited from class java.lang.Object

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

Constructor Detail

FixedDelayRestartBackoffTimeStrategyFactory

public FixedDelayRestartBackoffTimeStrategyFactory(int maxNumberRestartAttempts,
                                                   long backoffTimeMS)

Method Detail

create

public RestartBackoffTimeStrategy create()

Description copied from interface: RestartBackoffTimeStrategy.Factory

Instantiates the RestartBackoffTimeStrategy.

Specified by:

create in interface RestartBackoffTimeStrategy.Factory

Returns:

The instantiated restart strategy.