org.apache.spark.scheduler

Class Pool

Object

org.apache.spark.scheduler.Pool

All Implemented Interfaces:

Logging, Schedulable

public class Pool
extends Object
implements Schedulable, Logging

An Schedulable entity that represent collection of Pools or TaskSetManagers

Constructor Summary

Constructors

Constructor and Description
Pool(String poolName, scala.Enumeration.Value schedulingMode, int initMinShare, int initWeight)

Method Summary

Methods

Modifier and Type	Method and Description
void	addSchedulable(Schedulable schedulable)
boolean	checkSpeculatableTasks()
void	decreaseRunningTasks(int taskNum)
void	executorLost(String executorId, String host)
Schedulable	getSchedulableByName(String schedulableName)
scala.collection.mutable.ArrayBuffer<TaskSetManager>	getSortedTaskSetQueue()
void	increaseRunningTasks(int taskNum)
int	minShare()
String	name()
Pool	parent()
String	poolName()
int	priority()
void	removeSchedulable(Schedulable schedulable)
int	runningTasks()
java.util.concurrent.ConcurrentHashMap<String,Schedulable>	schedulableNameToSchedulable()
java.util.concurrent.ConcurrentLinkedQueue<Schedulable>	schedulableQueue()
scala.Enumeration.Value	schedulingMode()
int	stageId()
SchedulingAlgorithm	taskSetSchedulingAlgorithm()
int	weight()

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

Constructor Detail

Pool

public Pool(String poolName,
    scala.Enumeration.Value schedulingMode,
    int initMinShare,
    int initWeight)

Method Detail

poolName

public String poolName()

schedulingMode

public scala.Enumeration.Value schedulingMode()

Specified by:

schedulingMode in interface Schedulable

schedulableQueue

public java.util.concurrent.ConcurrentLinkedQueue<Schedulable> schedulableQueue()

Specified by:

schedulableQueue in interface Schedulable

schedulableNameToSchedulable

public java.util.concurrent.ConcurrentHashMap<String,Schedulable> schedulableNameToSchedulable()

weight

public int weight()

Specified by:

weight in interface Schedulable

minShare

public int minShare()

Specified by:

minShare in interface Schedulable

runningTasks

public int runningTasks()

Specified by:

runningTasks in interface Schedulable

priority

public int priority()

Specified by:

priority in interface Schedulable

stageId

public int stageId()

Specified by:

stageId in interface Schedulable

name

public String name()

Specified by:

name in interface Schedulable

parent

public Pool parent()

Specified by:

parent in interface Schedulable

taskSetSchedulingAlgorithm

public SchedulingAlgorithm taskSetSchedulingAlgorithm()

addSchedulable

public void addSchedulable(Schedulable schedulable)

Specified by:

addSchedulable in interface Schedulable

removeSchedulable

public void removeSchedulable(Schedulable schedulable)

Specified by:

removeSchedulable in interface Schedulable

getSchedulableByName

public Schedulable getSchedulableByName(String schedulableName)

Specified by:

getSchedulableByName in interface Schedulable

executorLost

public void executorLost(String executorId,
                String host)

Specified by:

executorLost in interface Schedulable

checkSpeculatableTasks

public boolean checkSpeculatableTasks()

Specified by:

checkSpeculatableTasks in interface Schedulable

getSortedTaskSetQueue

public scala.collection.mutable.ArrayBuffer<TaskSetManager> getSortedTaskSetQueue()

Specified by:

getSortedTaskSetQueue in interface Schedulable

increaseRunningTasks

public void increaseRunningTasks(int taskNum)

decreaseRunningTasks

public void decreaseRunningTasks(int taskNum)