Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair |
Modifier and Type | Method and Description |
---|---|
FSAppAttempt |
FSSchedulerNode.getReservedAppSchedulable() |
FSAppAttempt |
FairScheduler.getSchedulerApp(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId) |
Modifier and Type | Method and Description |
---|---|
List<FSAppAttempt> |
FSLeafQueue.getCopyOfNonRunnableAppSchedulables() |
List<FSAppAttempt> |
FSLeafQueue.getCopyOfRunnableAppSchedulables() |
protected HashMap<FSAppAttempt,org.apache.hadoop.yarn.api.records.Resource> |
FairScheduler.resToPreempt(FSLeafQueue sched,
long curTime)
Returns map of applications to resource that this queue is allowed to preempt, if any.
|
Modifier and Type | Method and Description |
---|---|
void |
FSLeafQueue.addApp(FSAppAttempt app,
boolean runnable) |
double |
WeightAdjuster.adjustWeight(FSAppAttempt app,
double curWeight) |
double |
NewAppWeightBooster.adjustWeight(FSAppAttempt app,
double curWeight) |
int |
FifoAppComparator.compare(FSAppAttempt a1,
FSAppAttempt a2) |
ResourceWeights |
FairScheduler.getAppWeight(FSAppAttempt app) |
boolean |
FSLeafQueue.isNonRunnableApp(FSAppAttempt attempt) |
boolean |
FSLeafQueue.isRunnableApp(FSAppAttempt attempt) |
boolean |
FSLeafQueue.removeApp(FSAppAttempt app)
Removes the given app from this queue.
|
boolean |
FSLeafQueue.removeNonRunnableApp(FSAppAttempt app)
Removes the given app if it is non-runnable and belongs to this queue
|
void |
MaxRunningAppsEnforcer.trackNonRunnableApp(FSAppAttempt app)
Tracks the given new non runnable app so that it can be made runnable when
it would not violate max running app limits.
|
void |
MaxRunningAppsEnforcer.trackRunnableApp(FSAppAttempt app)
Tracks the given new runnable app for purposes of maintaining max running
app limits.
|
void |
MaxRunningAppsEnforcer.untrackNonRunnableApp(FSAppAttempt app)
Stops tracking the given non-runnable app
|
void |
MaxRunningAppsEnforcer.untrackRunnableApp(FSAppAttempt app)
Updates the relevant tracking variables after a runnable app with the given
queue and user has been removed.
|
void |
MaxRunningAppsEnforcer.updateRunnabilityOnAppRemoval(FSAppAttempt app,
FSLeafQueue queue)
Checks to see whether any other applications runnable now that the given
application has been removed from the given queue.
|
Modifier and Type | Method and Description |
---|---|
protected void |
FairScheduler.preemptResources(HashMap<FSAppAttempt,org.apache.hadoop.yarn.api.records.Resource> toPreempt)
Preempt a quantity of resources.
|
Copyright © 2015 Apache Software Foundation. All Rights Reserved.