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

Class Evaluators

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable

public final class Evaluators
extends Object
implements AutoCloseable

Manages all Evaluators. See EvaluatorManager for the Driver side representation of a single Evaluator.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	allEvaluatorsAreClosed() Return true if all evaluators are in closed state (and their processing queues are empty).
void	close() Closes all EvaluatorManager instances managed.
Optional<EvaluatorManager>	get(String evaluatorId)
void	put(EvaluatorManager evaluatorManager) Adds an EvaluatorManager.
void	put(EvaluatorManagerFactory evaluatorManagerFactory, ResourceAllocationEvent evaluatorMsg) Create new EvaluatorManager and add it to the collection.
void	removeClosedEvaluator(EvaluatorManager evaluatorManager) Moves evaluator from map of active evaluators to set of closed evaluators.
boolean	wasClosed(String evaluatorId)

Methods inherited from class java.lang.Object

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

Method Detail

close

public void close()

Closes all EvaluatorManager instances managed.

Specified by:

close in interface AutoCloseable

allEvaluatorsAreClosed

public boolean allEvaluatorsAreClosed()

Return true if all evaluators are in closed state (and their processing queues are empty).

get

public Optional<EvaluatorManager> get(String evaluatorId)

Parameters:

evaluatorId -

Returns:

the EvaluatorManager for the given id, if one exists.

wasClosed

public boolean wasClosed(String evaluatorId)

Parameters:

evaluatorId -

Returns:

true if evaluator with this id has already been closed.

put

public void put(EvaluatorManagerFactory evaluatorManagerFactory,
       ResourceAllocationEvent evaluatorMsg)

Create new EvaluatorManager and add it to the collection.

FIXME: This method is a temporary fix for the race condition described in issues #828 and #839.

Parameters:

evaluatorManagerFactory - Factory that builds new EvaluatorManager objects.

evaluatorMsg - Resource allocation message that contains data on the new evaluator.

Throws:

IllegalArgumentException - if the EvaluatorManager is already known.

put

public void put(EvaluatorManager evaluatorManager)

Adds an EvaluatorManager.

Parameters:

evaluatorManager -

Throws:

IllegalArgumentException - if the EvaluatorManager is already known.

removeClosedEvaluator

public void removeClosedEvaluator(EvaluatorManager evaluatorManager)

Moves evaluator from map of active evaluators to set of closed evaluators.