Skip to content

ExecutorBackend

ExecutorBackend is an abstraction of executor backends (that TaskRunners use to report task status updates to a scheduler).

ExecutorBackend receives notifications from TaskRunners

ExecutorBackend acts as a bridge between executors and the driver.

Contract

Reporting Task Status

statusUpdate(
  taskId: Long,
  state: TaskState,
  data: ByteBuffer): Unit

Reports task status of the given task to a scheduler

See:

Used when:

Implementations