edu.snu.coral.runtime.master.scheduler

Interface SchedulingPolicy

All Known Implementing Classes:

RoundRobinSchedulingPolicy

@DefaultImplementation(value=RoundRobinSchedulingPolicy.class)
public interface SchedulingPolicy

Defines the policy by which BatchSingleJobScheduler assigns task groups to executors.

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.

Method Detail

getScheduleTimeoutMs

long getScheduleTimeoutMs()

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

Returns:

the timeout in milliseconds.

scheduleTaskGroup

boolean scheduleTaskGroup(ScheduledTaskGroup scheduledTaskGroup,
                          JobStateManager jobStateManager)

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)

Parameters:

scheduledTaskGroup - to schedule.

jobStateManager - jobStateManager which the TaskGroup belongs to.

Returns:

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

onExecutorAdded

void onExecutorAdded(String executorId)

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)

Parameters:

executorId - for the executor that has been added.

onExecutorRemoved

Set<String> onExecutorRemoved(String executorId)

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)

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

void onTaskGroupExecutionComplete(String executorId,
                                  String taskGroupId)

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)

Parameters:

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

taskGroupId - whose execution has completed.

onTaskGroupExecutionFailed

void onTaskGroupExecutionFailed(String executorId,
                                String taskGroupId)

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

Parameters:

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

taskGroupId - whose execution has completed.