pyflink.common.restart_strategy.RestartStrategies

class RestartStrategies

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.

Methods

failure_rate_restart(failure_rate, ...)	Generates a FailureRateRestartStrategyConfiguration.
fall_back_restart()
fixed_delay_restart(restart_attempts, ...)	Generates a FixedDelayRestartStrategyConfiguration.
no_restart()	Generates NoRestartStrategyConfiguration.