| Interface | Description |
|---|---|
| DAGSchedulerEvent |
Types of events that can be handled by the DAGScheduler.
|
| ExternalClusterManager |
A cluster manager interface to plugin external scheduler.
|
| JobListener |
Interface used to listen for job completion or failure events after submitting a job to the
DAGScheduler.
|
| JobResult | Developer API
A result of a job in the DAGScheduler.
|
| MapStatus |
Result returned by a ShuffleMapTask to a scheduler.
|
| OutputCommitCoordinationMessage | |
| Schedulable |
An interface for schedulable entities.
|
| SchedulableBuilder |
An interface to build Schedulable tree
buildPools: build the tree nodes(pools)
addTaskSetManager: build the leaf nodes(TaskSetManagers)
|
| SchedulerBackend |
A backend interface for scheduling systems that allows plugging in different ones under
TaskSchedulerImpl.
|
| SchedulingAlgorithm |
An interface for sort algorithm
FIFO: FIFO algorithm between TaskSetManagers
FS: FS algorithm between Pools, and FIFO or FS within Pools
|
| SparkListenerBus |
A
SparkListenerEvent bus that relays SparkListenerEvents to its listeners |
| SparkListenerEvent | |
| SparkListenerInterface |
Interface for listening to events from the Spark scheduler.
|
| TaskLocation |
A location where a task should run.
|
| TaskResult<T> | |
| TaskScheduler |
Low-level task scheduler interface, currently implemented exclusively by
TaskSchedulerImpl. |