org.apache.reef.runtime.common.driver.evaluator

Class EvaluatorManagerFactory

java.lang.Object

org.apache.reef.runtime.common.driver.evaluator.EvaluatorManagerFactory

public final class EvaluatorManagerFactory
extends Object

Helper class that creates new EvaluatorManager instances from allocations.

Method Summary

Methods

Modifier and Type	Method and Description
EvaluatorManager	getNewEvaluatorManagerForEvaluatorFailedDuringDriverRestart(ResourceStatusEvent resourceStatusEvent) Instantiates a new EvaluatorManager for a failed evaluator during driver restart.
EvaluatorManager	getNewEvaluatorManagerForNewEvaluator(ResourceAllocationEvent resourceAllocationEvent) Instantiates a new EvaluatorManager based on a resource allocation.
EvaluatorManager	getNewEvaluatorManagerForRecoveredEvaluator(ResourceRecoverEvent resourceRecoverEvent) Instantiates a new EvaluatorManager based on a resource allocation from a recovered evaluator.

Methods inherited from class java.lang.Object

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

Method Detail

getNewEvaluatorManagerForNewEvaluator

public EvaluatorManager getNewEvaluatorManagerForNewEvaluator(ResourceAllocationEvent resourceAllocationEvent)

Instantiates a new EvaluatorManager based on a resource allocation. Fires the EvaluatorAllocatedEvent.

Parameters:

resourceAllocationEvent -

Returns:

an EvaluatorManager for the newly allocated Evaluator.

getNewEvaluatorManagerForEvaluatorFailedDuringDriverRestart

public EvaluatorManager getNewEvaluatorManagerForEvaluatorFailedDuringDriverRestart(ResourceStatusEvent resourceStatusEvent)

Instantiates a new EvaluatorManager for a failed evaluator during driver restart. Does not fire an EvaluatorAllocatedEvent.

Parameters:

resourceStatusEvent -

Returns:

an EvaluatorManager for the user to call fail on.

getNewEvaluatorManagerForRecoveredEvaluator

public EvaluatorManager getNewEvaluatorManagerForRecoveredEvaluator(ResourceRecoverEvent resourceRecoverEvent)

Instantiates a new EvaluatorManager based on a resource allocation from a recovered evaluator.

Parameters:

resourceRecoverEvent -

Returns:

an EvaluatorManager for the newly allocated Evaluator.