Uses of Class
org.apache.drill.yarn.appMaster.Task

Packages that use Task

Package	Description
org.apache.drill.yarn.appMaster	Implements the Drill Application Master for YARN.
org.apache.drill.yarn.appMaster.http
org.apache.drill.yarn.zk	Interface between the Application Master and ZooKeeper.

Uses of Task in org.apache.drill.yarn.appMaster

Fields in org.apache.drill.yarn.appMaster declared as Task

Modifier and Type	Field and Description
Task	EventContext.task

Fields in org.apache.drill.yarn.appMaster with type parameters of type Task

Modifier and Type	Field and Description
protected Map<org.apache.hadoop.yarn.api.records.ContainerId,Task>	SchedulerStateImpl.activeContainers Tracks running tasks: those that have been allocated containers and are starting, running, failed or ended.
protected List<Task>	SchedulerStateImpl.allocatingTasks Tracks the tasks for which containers have been requested.
protected List<Task>	SchedulerStateImpl.pendingTasks Tracks the tasks to be started, but for which no work has yet been done.

Methods in org.apache.drill.yarn.appMaster that return Task

Modifier and Type	Method and Description
Task	Task.copy()
Task	SchedulerStateActions.getTask(int id)
Task	SchedulerStateImpl.getTask(int id)

Methods in org.apache.drill.yarn.appMaster that return types with arguments of type Task

Modifier and Type	Method and Description
List<Task>	SchedulerStateImpl.getActiveTasks()
List<Task>	SchedulerState.getActiveTasks() Returns the list of active tasks that have not yet been cancelled.
List<Task>	ClusterControllerImpl.getHistory()
List<Task>	SchedulerStateImpl.getStartingTasks()
List<Task>	SchedulerState.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.

Methods in org.apache.drill.yarn.appMaster with parameters of type Task

Modifier and Type	Method and Description
void	SchedulerStateActions.cancel(Task task)
void	SchedulerStateImpl.cancel(Task task)
void	SchedulerState.cancel(Task task)
void	BatchScheduler.completed(Task task)
void	Scheduler.completed(Task task)
void	PersistentTaskScheduler.completed(Task task) Indicate that a task is completed.
void	ClusterControllerImpl.completionAck(Task task, String propertyKey)
void	RegistryHandler.completionAck(Task task, String endpointProperty)
void	ClusterControllerImpl.containerAllocated(Task task)
void	SchedulerStateImpl.containerAllocated(Task task) Mark that a task has become active and should be tracked by its container ID.
void	ClusterControllerImpl.containerReleased(Task task)
void	SchedulerStateImpl.containerReleased(Task task) Mark that a task has completed: its container has expired or been revoked or the task has completed: successfully or a failure, as given by the task's disposition.
void	SchedulerStateImpl.dequeueAllocatingTask(Task task) Remove a task from the list of those waiting for a container allocation.
void	SchedulerStateImpl.dequeuePendingRequest(Task task) Remove a task from the queue of tasks waiting to send a container request.
void	SchedulerStateImpl.enqueueAllocatingTask(Task task) Put a task onto the queue awaiting an allocation response from YARN.
void	SchedulerStateImpl.enqueuePendingRequest(Task task) Put a task into the queue waiting to send a container request to YARN.
LaunchSpec	Scheduler.TaskManager.getLaunchSpec(Task task)
LaunchSpec	AbstractTaskManager.getLaunchSpec(Task task)
boolean	SchedulerStateImpl.requestStop(Task task) Request a graceful stop of the task.
void	EventContext.setTask(Task task)
void	SchedulerStateImpl.start(Task task) Define a new task in this group.
void	SchedulerState.start(Task task) Start the given task.
void	ClusterControllerImpl.startAck(Task task, String propertyKey, Object value)
void	RegistryHandler.startAck(Task task, String propertyKey, Object value)
boolean	Scheduler.TaskManager.stop(Task task)
boolean	AbstractTaskManager.stop(Task task)
void	ClusterControllerImpl.taskEnded(Task task)
void	SchedulerStateImpl.taskEnded(Task task) Mark that a task has completed successfully or a failure, as given by the task's disposition.
void	ClusterControllerImpl.taskRetried(Task task)
void	SchedulerStateImpl.taskRetried(Task task) Mark that a task is about to be retried.
void	TaskVisitor.visit(Task task)

Constructors in org.apache.drill.yarn.appMaster with parameters of type Task

Constructor and Description
EventContext(ClusterControllerImpl controller, Task task)
EventContext(Task task) For testing only, omits the controller and YARN.

Uses of Task in org.apache.drill.yarn.appMaster.http

Methods in org.apache.drill.yarn.appMaster.http with parameters of type Task

Modifier and Type	Method and Description
void	AbstractTasksModel.TasksModel.visit(Task task)

Constructors in org.apache.drill.yarn.appMaster.http with parameters of type Task

Constructor and Description
TaskModel(Task task, boolean live)

Uses of Task in org.apache.drill.yarn.zk

Subclasses of Task in org.apache.drill.yarn.zk

Modifier and Type	Class and Description
static class	TestZkRegistry.TestTask

Fields in org.apache.drill.yarn.zk declared as Task

Modifier and Type	Field and Description
protected Task	ZKRegistry.DrillbitTracker.task For Drillbits started by the AM, the task object for this Drillbit.

Methods in org.apache.drill.yarn.zk with parameters of type Task

Modifier and Type	Method and Description
boolean	ZKRegistry.isRegistered(Task task) Report whether the given task is still registered in ZK.

Constructors in org.apache.drill.yarn.zk with parameters of type Task

Constructor and Description
AckEvent(Task task, CoordinationProtos.DrillbitEndpoint endpoint)
DrillbitTracker(String key, Task task)