Skip to content


= ExecutorBackend

ExecutorBackend is a <> that[TaskRunners] use to <> to a scheduler.

.ExecutorBackend receives notifications from TaskRunners image::ExecutorBackend.png[align="center"]

NOTE: TaskRunner manages a single individual[task] and is managed by an[Executor to launch a task].

It is effectively a bridge between the driver and an executor, i.e. there are two endpoints running.

There are three concrete executor backends:


  •[] (for[Spark local])


== [[contract]] ExecutorBackend Contract

=== [[statusUpdate]] statusUpdate Method

[source, scala]

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

Used when TaskRunner is requested to[run a task] (to send task status updates).

Back to top