org.apache.reef.driver.restart

Class EvaluatorPreservingEvaluatorFailedHandler

java.lang.Object

org.apache.reef.driver.restart.EvaluatorPreservingEvaluatorFailedHandler

All Implemented Interfaces:

EventHandler<FailedEvaluator>

public final class EvaluatorPreservingEvaluatorFailedHandler
extends Object
implements EventHandler<FailedEvaluator>

Removes an evaluator from the evaluators to restart after it has failed.

Method Summary

Methods

Modifier and Type	Method and Description
void	onNext(FailedEvaluator value) Removes the completed evaluator from the list of evaluators to recover once it is failed.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

onNext

public void onNext(FailedEvaluator value)

Removes the completed evaluator from the list of evaluators to recover once it is failed.

Specified by:

onNext in interface EventHandler<FailedEvaluator>

Parameters:

value - The failed evaluator event.