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.