Schedulable Contract — Schedulable Entities

Schedulable is the abstraction of schedulable entities that manages the schedulableQueue and can getSortedTaskSetQueue.

Table 1. Schedulable Contract
Method Description

addSchedulable

addSchedulable(schedulable: Schedulable): Unit

Registers a Schedulable

Used when:

checkSpeculatableTasks

checkSpeculatableTasks(minTimeToSpeculation: Int): Boolean

Used when…​FIXME

executorLost

executorLost(
  executorId: String,
  host: String,
  reason: ExecutorLossReason): Unit

Handles an executor lost event

Used when:

getSchedulableByName

getSchedulableByName(name: String): Schedulable

Finds a Schedulable by name

Used when…​FIXME

getSortedTaskSetQueue

getSortedTaskSetQueue: ArrayBuffer[TaskSetManager]

Builds a collection of TaskSetManagers sorted by priority

Used when:

minShare

minShare: Int

Used when…​FIXME

name

name: String

Used when…​FIXME

parent

parent: Pool

Used when…​FIXME

priority

priority: Int

Used when…​FIXME

removeSchedulable

removeSchedulable(schedulable: Schedulable): Unit

Used when…​FIXME

runningTasks

runningTasks: Int

Used when…​FIXME

schedulableQueue

schedulableQueue: ConcurrentLinkedQueue[Schedulable]

Used when:

schedulingMode

schedulingMode: SchedulingMode

Used when:

  • Pool is created

  • web UI’s PoolTable is requested to render a page with pools (poolRow)

stageId

stageId: Int

Used when…​FIXME

weight

weight: Int

Used when…​FIXME

Table 2. Schedulables
Schedulable Description

Pool

Pool of schedulables (i.e. a recursive data structure for prioritizing task sets)

TaskSetManager

Manages scheduling of tasks of a TaskSet

results matching ""

    No results matching ""