public final class RestartBackoffTimeStrategyFactoryLoader extends Object
RestartBackoffTimeStrategy.Factory
from the configuration.Modifier and Type | Method and Description |
---|---|
static RestartBackoffTimeStrategy.Factory |
createRestartBackoffTimeStrategyFactory(RestartStrategies.RestartStrategyConfiguration jobRestartStrategyConfiguration,
Configuration clusterConfiguration,
boolean isCheckpointingEnabled)
Creates
RestartBackoffTimeStrategy.Factory from the given configuration. |
public static RestartBackoffTimeStrategy.Factory createRestartBackoffTimeStrategyFactory(RestartStrategies.RestartStrategyConfiguration jobRestartStrategyConfiguration, Configuration clusterConfiguration, boolean isCheckpointingEnabled)
RestartBackoffTimeStrategy.Factory
from the given configuration.
The strategy factory is decided in order as follows:
RestartStrategies.RestartStrategyConfiguration
, unless the config is RestartStrategies.FallbackRestartStrategyConfiguration
.
FixedDelayRestartBackoffTimeStrategy.FixedDelayRestartBackoffTimeStrategyFactory
if
checkpointing is enabled. Otherwise NoRestartBackoffTimeStrategy.NoRestartBackoffTimeStrategyFactory
jobRestartStrategyConfiguration
- restart configuration given within the job graphclusterConfiguration
- cluster(server-side) configurationisCheckpointingEnabled
- if checkpointing is enabled for the jobCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.