@DefaultImplementation(value=org.apache.reef.driver.restart.DefaultDriverRuntimeRestartMangerImpl.class) public interface DriverRuntimeRestartManager
Modifier and Type | Method and Description |
---|---|
RestartEvaluators |
getPreviousEvaluators()
Gets the sets of alive and failed evaluators based on the runtime implementation.
|
int |
getResubmissionAttempts() |
void |
informAboutEvaluatorFailures(Set<String> failedEvaluatorIds)
Informs the necessary components about failed evaluators.
|
void |
recordAllocatedEvaluator(String id)
Records the evaluators when it is allocated.
|
void |
recordRemovedEvaluator(String id)
Records a removed evaluator into the evaluator log.
|
int getResubmissionAttempts()
void recordAllocatedEvaluator(String id)
id
- The evaluator ID of the allocated evaluator.void recordRemovedEvaluator(String id)
id
- The evaluator ID of the removed evaluator.RestartEvaluators getPreviousEvaluators()
void informAboutEvaluatorFailures(Set<String> failedEvaluatorIds)
failedEvaluatorIds
- The set of evaluator IDs of evaluators that failed during restart.Copyright © 2017 The Apache Software Foundation. All rights reserved.