org.apache.spark.scheduler

Interface SchedulerBackend

All Known Implementing Classes:

CoarseGrainedSchedulerBackend, CoarseMesosSchedulerBackend, LocalBackend, MesosSchedulerBackend, SimrSchedulerBackend, SparkDeploySchedulerBackend, YarnSchedulerBackend

public interface SchedulerBackend

A backend interface for scheduling systems that allows plugging in different ones under TaskSchedulerImpl. We assume a Mesos-like model where the application gets resource offers as machines become available and can launch tasks on them.

Method Summary

Methods

Modifier and Type	Method and Description
String	appId()
String	applicationId() Get an application ID associated with the job.
int	defaultParallelism()
boolean	isReady()
void	killTask(long taskId, String executorId, boolean interruptThread)
void	reviveOffers()
void	start()
void	stop()

Method Detail

appId

String appId()

start

void start()

stop

void stop()

reviveOffers

void reviveOffers()

defaultParallelism

int defaultParallelism()

killTask

void killTask(long taskId,
            String executorId,
            boolean interruptThread)

isReady

boolean isReady()

applicationId

String applicationId()

Get an application ID associated with the job.

Returns:

An application ID