edu.snu.coral.runtime.master.scheduler

Class RoundRobinSchedulingPolicy

java.lang.Object

edu.snu.coral.runtime.master.scheduler.RoundRobinSchedulingPolicy

All Implemented Interfaces:

SchedulingPolicy

@ThreadSafe
public final class RoundRobinSchedulingPolicy
extends Object
implements SchedulingPolicy

A Round-Robin implementation used by BatchSingleJobScheduler. This policy keeps a list of available ExecutorRepresenter for each type of container. The RR policy is used for each container type when trying to schedule a task group.

Constructor Summary

Constructors

Constructor and Description
RoundRobinSchedulingPolicy(ContainerManager containerManager, int scheduleTimeoutMs)

Method Summary

Modifier and Type	Method and Description
long	getScheduleTimeoutMs() Returns this scheduling policy's timeout before an executor assignment.
void	onExecutorAdded(String executorId) Adds the executorId to the pool of available executors.
Set<String>	onExecutorRemoved(String executorId) Deletes the executorId from the pool of available executors.
void	onTaskGroupExecutionComplete(String executorId, String taskGroupId) Marks the taskGroup's completion in the executor.
void	onTaskGroupExecutionFailed(String executorId, String taskGroupId) Marks the taskGroup's failure in the executor.
boolean	scheduleTaskGroup(ScheduledTaskGroup scheduledTaskGroup, JobStateManager jobStateManager) Attempts to schedule the given taskGroup to an executor according to this policy.

Methods inherited from class java.lang.Object

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

Constructor Detail

RoundRobinSchedulingPolicy

@Inject
public RoundRobinSchedulingPolicy(ContainerManager containerManager,
                                          int scheduleTimeoutMs)

Method Detail

getScheduleTimeoutMs

public long getScheduleTimeoutMs()

Description copied from interface: SchedulingPolicy

Returns this scheduling policy's timeout before an executor assignment.

Specified by:

getScheduleTimeoutMs in interface SchedulingPolicy

Returns:

the timeout in milliseconds.

scheduleTaskGroup

public boolean scheduleTaskGroup(ScheduledTaskGroup scheduledTaskGroup,
                                 JobStateManager jobStateManager)

Description copied from interface: SchedulingPolicy

Attempts to schedule the given taskGroup to an executor according to this policy. If there is no executor available for the taskGroup, it waits for an executor to be assigned before it times out. (Depending on the executor's resource type)

Specified by:

scheduleTaskGroup in interface SchedulingPolicy

Parameters:

scheduledTaskGroup - to schedule.

jobStateManager - jobStateManager which the TaskGroup belongs to.

Returns:

true if the task group is successfully scheduled, false otherwise.

onExecutorAdded

public void onExecutorAdded(String executorId)

Description copied from interface: SchedulingPolicy

Adds the executorId to the pool of available executors. Unlocks this policy to schedule a next taskGroup if locked. (Depending on the executor's resource type)

Specified by:

onExecutorAdded in interface SchedulingPolicy

Parameters:

executorId - for the executor that has been added.

onExecutorRemoved

public Set<String> onExecutorRemoved(String executorId)

Description copied from interface: SchedulingPolicy

Deletes the executorId from the pool of available executors. Locks this policy from scheduling if there is no more executor currently available for the next taskGroup. (Depending on the executor's resource type)

Specified by:

onExecutorRemoved in interface SchedulingPolicy

Parameters:

executorId - for the executor that has been deleted.

Returns:

the ids of the set of task groups that were running on the executor.

onTaskGroupExecutionComplete

public void onTaskGroupExecutionComplete(String executorId,
                                         String taskGroupId)

Description copied from interface: SchedulingPolicy

Marks the taskGroup's completion in the executor. Unlocks this policy to schedule a next taskGroup if locked. (Depending on the executor's resource type)

Specified by:

onTaskGroupExecutionComplete in interface SchedulingPolicy

Parameters:

executorId - of the executor where the taskGroup's execution has completed.

taskGroupId - whose execution has completed.

onTaskGroupExecutionFailed

public void onTaskGroupExecutionFailed(String executorId,
                                       String taskGroupId)

Description copied from interface: SchedulingPolicy

Marks the taskGroup's failure in the executor. Unlocks this policy to reschedule this taskGroup if locked. (Depending on the executor's resource type)

Specified by:

onTaskGroupExecutionFailed in interface SchedulingPolicy

Parameters:

executorId - of the executor where the taskGroup's execution has failed.

taskGroupId - whose execution has completed.