public interface Schedulable
Modifier and Type | Method and Description |
---|---|
void |
addSchedulable(Schedulable schedulable) |
boolean |
checkSpeculatableTasks() |
void |
executorLost(String executorId,
String host) |
Schedulable |
getSchedulableByName(String name) |
scala.collection.mutable.ArrayBuffer<TaskSetManager> |
getSortedTaskSetQueue() |
int |
minShare() |
String |
name() |
Pool |
parent() |
int |
priority() |
void |
removeSchedulable(Schedulable schedulable) |
int |
runningTasks() |
java.util.concurrent.ConcurrentLinkedQueue<Schedulable> |
schedulableQueue() |
scala.Enumeration.Value |
schedulingMode() |
int |
stageId() |
int |
weight() |
Pool parent()
java.util.concurrent.ConcurrentLinkedQueue<Schedulable> schedulableQueue()
scala.Enumeration.Value schedulingMode()
int weight()
int minShare()
int runningTasks()
int priority()
int stageId()
String name()
void addSchedulable(Schedulable schedulable)
void removeSchedulable(Schedulable schedulable)
Schedulable getSchedulableByName(String name)
void executorLost(String executorId, String host)
boolean checkSpeculatableTasks()
scala.collection.mutable.ArrayBuffer<TaskSetManager> getSortedTaskSetQueue()