org.apache.spark.scheduler.cluster

Class SimrSchedulerBackend

Object

org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend

org.apache.spark.scheduler.cluster.SimrSchedulerBackend

All Implemented Interfaces:

ExecutorAllocationClient, Logging, SchedulerBackend

public class SimrSchedulerBackend
extends CoarseGrainedSchedulerBackend
implements Logging

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend

CoarseGrainedSchedulerBackend.DriverActor

Constructor Summary

Constructors

Constructor and Description
SimrSchedulerBackend(TaskSchedulerImpl scheduler, SparkContext sc, String driverFilePath)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.fs.Path	filePath()
int	maxCores()
void	start()
void	stop()
org.apache.hadoop.fs.Path	tmpPath()

Methods inherited from class org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend

ACTOR_NAME, actorSystem, conf, createTime, defaultParallelism, driverActor, isReady, killExecutors, killTask, maxRegisteredWaitingTime, minRegisteredRatio, numExistingExecutors, removeExecutor, requestExecutors, reviveOffers, stopExecutors, sufficientResourcesRegistered, taskIdsOnSlave, totalCoreCount, totalRegisteredExecutors

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Methods inherited from interface org.apache.spark.ExecutorAllocationClient

killExecutor

Methods inherited from interface org.apache.spark.scheduler.SchedulerBackend

appId, applicationId

Constructor Detail

SimrSchedulerBackend

public SimrSchedulerBackend(TaskSchedulerImpl scheduler,
                    SparkContext sc,
                    String driverFilePath)

Method Detail

tmpPath

public org.apache.hadoop.fs.Path tmpPath()

filePath

public org.apache.hadoop.fs.Path filePath()

maxCores

public int maxCores()

start

public void start()

Specified by:

start in interface SchedulerBackend

Overrides:

start in class CoarseGrainedSchedulerBackend

stop

public void stop()

Specified by:

stop in interface SchedulerBackend

Overrides:

stop in class CoarseGrainedSchedulerBackend