public class Pool extends Object implements Schedulable, Logging
Constructor and Description |
---|
Pool(String poolName,
scala.Enumeration.Value schedulingMode,
int initMinShare,
int initWeight) |
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() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public Pool(String poolName, scala.Enumeration.Value schedulingMode, int initMinShare, int initWeight)
public String poolName()
public scala.Enumeration.Value schedulingMode()
schedulingMode
in interface Schedulable
public java.util.concurrent.ConcurrentLinkedQueue<Schedulable> schedulableQueue()
schedulableQueue
in interface Schedulable
public java.util.concurrent.ConcurrentHashMap<String,Schedulable> schedulableNameToSchedulable()
public int weight()
weight
in interface Schedulable
public int minShare()
minShare
in interface Schedulable
public int runningTasks()
runningTasks
in interface Schedulable
public int priority()
priority
in interface Schedulable
public int stageId()
stageId
in interface Schedulable
public String name()
name
in interface Schedulable
public Pool parent()
parent
in interface Schedulable
public SchedulingAlgorithm taskSetSchedulingAlgorithm()
public void addSchedulable(Schedulable schedulable)
addSchedulable
in interface Schedulable
public void removeSchedulable(Schedulable schedulable)
removeSchedulable
in interface Schedulable
public Schedulable getSchedulableByName(String schedulableName)
getSchedulableByName
in interface Schedulable
public void executorLost(String executorId, String host)
executorLost
in interface Schedulable
public boolean checkSpeculatableTasks()
checkSpeculatableTasks
in interface Schedulable
public scala.collection.mutable.ArrayBuffer<TaskSetManager> getSortedTaskSetQueue()
getSortedTaskSetQueue
in interface Schedulable
public void increaseRunningTasks(int taskNum)
public void decreaseRunningTasks(int taskNum)