edu.snu.coral.runtime.master.resource

Class ExecutorRepresenter

java.lang.Object

edu.snu.coral.runtime.master.resource.ExecutorRepresenter

public final class ExecutorRepresenter
extends Object

Contains information/state regarding an executor. Such information may include: a) The executor's resource type. b) The executor's capacity (ex. number of cores). c) Task groups scheduled/launched for the executor. d) (Please add other information as we implement more features).

Constructor Summary

Constructors

Constructor and Description
ExecutorRepresenter(String executorId, ResourceSpecification resourceSpecification, MessageSender<edu.snu.coral.runtime.common.comm.ControlMessage.Message> messageSender, org.apache.reef.driver.context.ActiveContext activeContext, ExecutorService serializationExecutorService)

Method Summary

Modifier and Type	Method and Description
Set<String>	getCompleteTaskGroups()
String	getContainerType()
int	getExecutorCapacity()
String	getExecutorId()
Set<String>	getRunningTaskGroups()
void	onExecutorFailed()
void	onTaskGroupExecutionComplete(String taskGroupId)
void	onTaskGroupExecutionFailed(String taskGroupId)
void	onTaskGroupScheduled(ScheduledTaskGroup scheduledTaskGroup)
void	sendControlMessage(edu.snu.coral.runtime.common.comm.ControlMessage.Message message)
void	shutDown()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorRepresenter

public ExecutorRepresenter(String executorId,
                           ResourceSpecification resourceSpecification,
                           MessageSender<edu.snu.coral.runtime.common.comm.ControlMessage.Message> messageSender,
                           org.apache.reef.driver.context.ActiveContext activeContext,
                           ExecutorService serializationExecutorService)

Method Detail

onExecutorFailed

public void onExecutorFailed()

onTaskGroupScheduled

public void onTaskGroupScheduled(ScheduledTaskGroup scheduledTaskGroup)

sendControlMessage

public void sendControlMessage(edu.snu.coral.runtime.common.comm.ControlMessage.Message message)

onTaskGroupExecutionComplete

public void onTaskGroupExecutionComplete(String taskGroupId)

onTaskGroupExecutionFailed

public void onTaskGroupExecutionFailed(String taskGroupId)

getExecutorCapacity

public int getExecutorCapacity()

getRunningTaskGroups

public Set<String> getRunningTaskGroups()

getCompleteTaskGroups

public Set<String> getCompleteTaskGroups()

getExecutorId

public String getExecutorId()

getContainerType

public String getContainerType()

shutDown

public void shutDown()

toString

public String toString()

Overrides:

toString in class Object