SchedulerStateActions (Drill : 1.20.3 API)

All Known Implementing Classes:

SchedulerStateImpl
```
public interface SchedulerStateActions
```
Represents the set of commands called by the cluster controller to manage the state of tasks within a task group. Each task group is managed by a scheduler.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`adjustTasks()` Adjust the number of running tasks as needed to balance the number of running tasks with the desired number.
`void`	`cancel(Task task)`
`void`	`checkTasks(EventContext context, long curTime)`
`void`	`containerAllocated(EventContext context, org.apache.hadoop.yarn.api.records.Container container)` A container request has been granted.
`int`	`getLiveCount()`
`String`	`getName()` Returns the name of the scheduler associated with this task action group.
`int`	`getRequestCount()`
`Scheduler`	`getScheduler()` Returns the scheduler associated with this task group.
`Task`	`getTask(int id)`
`int`	`getTaskCount()`
`boolean`	`isDone()` Determine if this task group is done.
`boolean`	`requestContainers(EventContext context, int maxRequests)` Request a container the first task that we wish to start.
`void`	`shutDown(EventContext context)` Shut down this task group by canceling all tasks not already cancelled.
`void`	`visitTaskModels(TaskVisitor visitor)`

- Method Detail
  - getName
```
String getName()
```
    Returns the name of the scheduler associated with this task action group.
    
    Returns:
    
    The name of the scheduler associated with this task action group.
  - getScheduler
```
Scheduler getScheduler()
```
    Returns the scheduler associated with this task group.
    
    Returns:
    
    The scheduler associated with this task group.
  - adjustTasks
```
void adjustTasks()
```
    Adjust the number of running tasks as needed to balance the number of running tasks with the desired number. May result in no change it the cluster is already in balance (or is in the process of achieving balance.)
  - requestContainers
```
boolean requestContainers(EventContext context,
                          int maxRequests)
```
    Request a container the first task that we wish to start.
  - containerAllocated
```
void containerAllocated(EventContext context,
                        org.apache.hadoop.yarn.api.records.Container container)
```
    A container request has been granted. Match the container up with the first task waiting for a container and launch the task.
    
    Parameters:
    
    context -
    
    container -
  - shutDown
```
void shutDown(EventContext context)
```
    Shut down this task group by canceling all tasks not already cancelled.
    
    Parameters:
    
    context -
  - isDone
```
boolean isDone()
```
    Determine if this task group is done. It is done when there are no active tasks and the controller itself is shutting down. This latter check differentiates the start state (when no tasks are active) from the end state. The AM will not shut down until all task groups are done.
    
    Returns:
    
    True if this task group is done. False otherwise.
  - getTaskCount
```
int getTaskCount()
```
  - getLiveCount
```
int getLiveCount()
```
  - getRequestCount
```
int getRequestCount()
```
  - visitTaskModels
```
void visitTaskModels(TaskVisitor visitor)
```
  - checkTasks
```
void checkTasks(EventContext context,
                long curTime)
```
  - cancel
```
void cancel(Task task)
```
  - getTask
```
Task getTask(int id)
```

Interface SchedulerStateActions

Method Summary

Method Detail

getName

getScheduler

adjustTasks

requestContainers

containerAllocated

shutDown

isDone

getTaskCount

getLiveCount

getRequestCount

visitTaskModels

checkTasks

cancel

getTask