public class FailureRateRestartStrategy extends Object implements RestartStrategy
ExecutionGraph
when failure rate exceeded
with a fixed time delay in between.Modifier and Type | Class and Description |
---|---|
static class |
FailureRateRestartStrategy.FailureRateRestartStrategyFactory |
Constructor and Description |
---|
FailureRateRestartStrategy(int maxFailuresPerInterval,
Time failuresInterval,
Time delayInterval) |
Modifier and Type | Method and Description |
---|---|
boolean |
canRestart()
True if the restart strategy can be applied to restart the
ExecutionGraph . |
static FailureRateRestartStrategy.FailureRateRestartStrategyFactory |
createFactory(Configuration configuration) |
void |
restart(RestartCallback restarter,
ScheduledExecutor executor)
Called by the ExecutionGraph to eventually trigger a full recovery.
|
String |
toString() |
public boolean canRestart()
RestartStrategy
ExecutionGraph
.canRestart
in interface RestartStrategy
public void restart(RestartCallback restarter, ScheduledExecutor executor)
RestartStrategy
The thread that calls this method is not supposed to block/sleep.
restart
in interface RestartStrategy
restarter
- The hook to restart the ExecutionGraphexecutor
- An scheduled executor to delay the restartpublic static FailureRateRestartStrategy.FailureRateRestartStrategyFactory createFactory(Configuration configuration) throws Exception
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.