pyflink.common.restart_strategy.RestartStrategies#

class RestartStrategies[source]#

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.