edu.snu.coral.runtime.master.resource

Class ContainerManager

java.lang.Object

edu.snu.coral.runtime.master.resource.ContainerManager

public final class ContainerManager
extends Object

Encapsulates REEF's evaluator management for executors. Serves as a single point of container/executor management in Runtime. We define a unit of resource a container (an evaluator in REEF), and launch a single executor on each container.

Constructor Summary

Constructors

Constructor and Description
ContainerManager(int scheduleSerThread, org.apache.reef.driver.evaluator.EvaluatorRequestor evaluatorRequestor, MessageEnvironment messageEnvironment)

Method Summary

Modifier and Type	Method and Description
Map<String,ExecutorRepresenter>	getExecutorRepresenterMap()
Map<String,ExecutorRepresenter>	getFailedExecutorRepresenterMap()
void	onContainerAllocated(String executorId, org.apache.reef.driver.evaluator.AllocatedEvaluator allocatedContainer, org.apache.reef.tang.Configuration executorConfiguration) Take the necessary actions in container manager once a container a is allocated.
void	onExecutorLaunched(org.apache.reef.driver.context.ActiveContext activeContext) Initializes master's connection to the executor once launched.
void	onExecutorRemoved(String failedExecutorId)
void	requestContainer(int numToRequest, ResourceSpecification resourceSpecification) Requests containers/evaluators with the given specifications.
Future<Boolean>	terminate() Terminates ContainerManager.

Methods inherited from class java.lang.Object

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

Constructor Detail

ContainerManager

@Inject
public ContainerManager(int scheduleSerThread,
                                org.apache.reef.driver.evaluator.EvaluatorRequestor evaluatorRequestor,
                                MessageEnvironment messageEnvironment)

Method Detail

requestContainer

public void requestContainer(int numToRequest,
                             ResourceSpecification resourceSpecification)

Requests containers/evaluators with the given specifications.

Parameters:

numToRequest - number of containers to request

resourceSpecification - containing the specifications of

onContainerAllocated

public void onContainerAllocated(String executorId,
                                 org.apache.reef.driver.evaluator.AllocatedEvaluator allocatedContainer,
                                 org.apache.reef.tang.Configuration executorConfiguration)

Take the necessary actions in container manager once a container a is allocated.

Parameters:

executorId - of the executor to launch on this container.

allocatedContainer - the allocated container.

executorConfiguration - executor related configuration.

onExecutorLaunched

public void onExecutorLaunched(org.apache.reef.driver.context.ActiveContext activeContext)

Initializes master's connection to the executor once launched. A representation of the executor to reside in master is created.

Parameters:

activeContext - for the launched executor.

onExecutorRemoved

public void onExecutorRemoved(String failedExecutorId)

getExecutorRepresenterMap

public Map<String,ExecutorRepresenter> getExecutorRepresenterMap()

getFailedExecutorRepresenterMap

public Map<String,ExecutorRepresenter> getFailedExecutorRepresenterMap()

terminate

public Future<Boolean> terminate()

Terminates ContainerManager. Before we terminate, we must wait for all the executors we requested and shutdown all of them if any of them is running.

Returns:

a future that returns a boolean on whether all requested resources were allocated and released.