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(ExecutionGraph executionGraph)
Restarts the given
ExecutionGraph . |
String |
toString() |
public boolean canRestart()
RestartStrategy
ExecutionGraph
.canRestart
in interface RestartStrategy
public void restart(ExecutionGraph executionGraph)
RestartStrategy
ExecutionGraph
.restart
in interface RestartStrategy
executionGraph
- The ExecutionGraph to be restartedpublic static FailureRateRestartStrategy.FailureRateRestartStrategyFactory createFactory(Configuration configuration) throws Exception
Exception
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.