| Interface | Description |
|---|---|
| PendingTaskGroupQueue |
Keep tracks of all pending task groups.
|
| Scheduler |
Receives jobs to execute and schedules
ScheduledTaskGroup to executors. |
| SchedulingPolicy |
Defines the policy by which
BatchSingleJobScheduler assigns task groups to executors. |
| Class | Description |
|---|---|
| BatchSingleJobScheduler |
BatchSingleJobScheduler receives a single
PhysicalPlan to execute and schedules the TaskGroups. |
| RoundRobinSchedulingPolicy |
A Round-Robin implementation used by
BatchSingleJobScheduler. |
| SchedulerRunner |
Takes a TaskGroup from the pending queue and schedules it to an executor.
|
| SingleJobTaskGroupQueue |
Keep tracks of all pending task groups.
|
Copyright © 2018. All rights reserved.