org.apache.drill.yarn.appMaster

Interface SchedulerState

All Known Implementing Classes:

SchedulerStateImpl

public interface SchedulerState

The cluster state for tasks managed by a scheduler. Abstracts away the details of managing tasks, allowing the scheduler to work only with overall number of tasks.

Method Summary

Modifier and Type	Method and Description
void	cancel(Task task)
List<Task>	getActiveTasks() Returns the list of active tasks that have not yet been cancelled.
int	getCancelledTaskCount() The number of active tasks that have been cancelled, but have not yet ended.
ClusterController	getController()
List<Task>	getStartingTasks() Returns the list of tasks awaiting a container request to be sent to YARN or for which a container request has been sent to YARN, but no container allocation has yet been received.
int	getTaskCount() The number of tasks in any active (non-ended) lifecycle state.
void	start(Task task) Start the given task.

Method Detail

getTaskCount

int getTaskCount()

The number of tasks in any active (non-ended) lifecycle state.

Returns:

The number of tasks in any active (non-ended) lifecycle state.

getCancelledTaskCount

int getCancelledTaskCount()

The number of active tasks that have been cancelled, but have not yet ended.

getStartingTasks

List<Task> getStartingTasks()

Returns the list of tasks awaiting a container request to be sent to YARN or for which a container request has been sent to YARN, but no container allocation has yet been received. Such tasks are simple to cancel. The list does not contain any tasks in this state which have previously been cancelled.

Returns:

The list of tasks awaiting a container request to be sent to YARN or for which a container request has been sent to YARN, but no container allocation has yet been received.

getActiveTasks

List<Task> getActiveTasks()

Returns the list of active tasks that have not yet been cancelled. Active tasks are any task for which a container has been assigned, but has not yet received a RM container completion event.

Returns:

The list of active tasks that have not yet been cancelled.

start

void start(Task task)

Start the given task.

Parameters:

task -

cancel

void cancel(Task task)

getController

ClusterController getController()