org.apache.reef.driver.restart

Class EvaluatorPreservingEvaluatorAllocatedHandler

java.lang.Object

org.apache.reef.driver.restart.EvaluatorPreservingEvaluatorAllocatedHandler

All Implemented Interfaces:

EventHandler<AllocatedEvaluator>

public final class EvaluatorPreservingEvaluatorAllocatedHandler
extends Object
implements EventHandler<AllocatedEvaluator>

Records allocated evaluators for recovery on driver restart by using a DriverRuntimeRestartManager.

Method Summary

Modifier and Type	Method and Description
void	onNext(AllocatedEvaluator value) Records the allocatedEvaluator ID with the DriverRuntimeRestartManager.

Methods inherited from class java.lang.Object

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

Method Detail

onNext

public void onNext(AllocatedEvaluator value)

Records the allocatedEvaluator ID with the DriverRuntimeRestartManager.

Specified by:

onNext in interface EventHandler<AllocatedEvaluator>

Parameters:

value - the allocated evaluator event.