org.apache.reef.driver.restart

Class EvaluatorPreservingEvaluatorCompletedHandler

java.lang.Object

org.apache.reef.driver.restart.EvaluatorPreservingEvaluatorCompletedHandler

All Implemented Interfaces:

EventHandler<CompletedEvaluator>

public final class EvaluatorPreservingEvaluatorCompletedHandler
extends Object
implements EventHandler<CompletedEvaluator>

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

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Method Detail

onNext

public void onNext(CompletedEvaluator value)

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

Specified by:

onNext in interface EventHandler<CompletedEvaluator>

Parameters:

value - The completed evaluator event.