|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.Schedulable
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.AppSchedulable
@InterfaceAudience.Private @InterfaceStability.Unstable public class AppSchedulable
Constructor Summary | |
---|---|
AppSchedulable(FairScheduler scheduler,
FSSchedulerApp app,
FSLeafQueue queue)
|
Method Summary | |
---|---|
org.apache.hadoop.yarn.api.records.Resource |
assignContainer(FSSchedulerNode node)
Assign a container on this node if possible, and return the amount of resources assigned. |
org.apache.hadoop.yarn.api.records.Resource |
assignReservedContainer(FSSchedulerNode node)
|
org.apache.hadoop.yarn.api.records.Container |
createContainer(FSSchedulerApp application,
FSSchedulerNode node,
org.apache.hadoop.yarn.api.records.Resource capability,
org.apache.hadoop.yarn.api.records.Priority priority)
Create and return a container object reflecting an allocation for the given appliction on the given node with the given capability and priority. |
FSSchedulerApp |
getApp()
|
org.apache.hadoop.yarn.api.records.Resource |
getDemand()
Maximum number of resources required by this Schedulable. |
org.apache.hadoop.yarn.api.records.Resource |
getMaxShare()
Maximum Resource share assigned to the schedulable. |
QueueMetrics |
getMetrics()
Get metrics reference from containing queue. |
org.apache.hadoop.yarn.api.records.Resource |
getMinShare()
Minimum Resource share assigned to the schedulable. |
String |
getName()
Name of job/queue, used for debugging as well as for breaking ties in scheduling order deterministically. |
org.apache.hadoop.yarn.api.records.Priority |
getPriority()
Job priority for jobs in FIFO queues; meaningless for QueueSchedulables. |
org.apache.hadoop.yarn.api.records.Resource |
getResourceUsage()
Get the aggregate amount of resources consumed by the schedulable. |
boolean |
getRunnable()
Is this application runnable? Runnable means that the user and queue application counts are within configured quotas. |
long |
getStartTime()
Start time for jobs in FIFO queues; meaningless for QueueSchedulables. |
ResourceWeights |
getWeights()
Job/queue weight in fair sharing. |
boolean |
hasContainerForNode(org.apache.hadoop.yarn.api.records.Priority prio,
FSSchedulerNode node)
Whether this app has containers requests that could be satisfied on the given node, if the node had full space. |
void |
setRunnable(boolean runnable)
|
void |
unreserve(org.apache.hadoop.yarn.api.records.Priority priority,
FSSchedulerNode node)
Remove the reservation on node at the given
Priority . |
void |
updateDemand()
Refresh the Schedulable's demand and those of its children if any. |
Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.Schedulable |
---|
getFairShare, setFairShare, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public AppSchedulable(FairScheduler scheduler, FSSchedulerApp app, FSLeafQueue queue)
Method Detail |
---|
public String getName()
Schedulable
getName
in class Schedulable
public FSSchedulerApp getApp()
public void updateDemand()
Schedulable
updateDemand
in class Schedulable
public org.apache.hadoop.yarn.api.records.Resource getDemand()
Schedulable
getDemand
in class Schedulable
public long getStartTime()
Schedulable
getStartTime
in class Schedulable
public org.apache.hadoop.yarn.api.records.Resource getResourceUsage()
Schedulable
getResourceUsage
in class Schedulable
public org.apache.hadoop.yarn.api.records.Resource getMinShare()
Schedulable
getMinShare
in class Schedulable
public org.apache.hadoop.yarn.api.records.Resource getMaxShare()
Schedulable
getMaxShare
in class Schedulable
public QueueMetrics getMetrics()
public ResourceWeights getWeights()
Schedulable
getWeights
in class Schedulable
public org.apache.hadoop.yarn.api.records.Priority getPriority()
Schedulable
getPriority
in class Schedulable
public boolean getRunnable()
public void setRunnable(boolean runnable)
public org.apache.hadoop.yarn.api.records.Container createContainer(FSSchedulerApp application, FSSchedulerNode node, org.apache.hadoop.yarn.api.records.Resource capability, org.apache.hadoop.yarn.api.records.Priority priority)
public void unreserve(org.apache.hadoop.yarn.api.records.Priority priority, FSSchedulerNode node)
node
at the given
Priority
. This dispatches to the SchedulerApp and SchedulerNode
handlers for an unreservation.
public org.apache.hadoop.yarn.api.records.Resource assignReservedContainer(FSSchedulerNode node)
public org.apache.hadoop.yarn.api.records.Resource assignContainer(FSSchedulerNode node)
Schedulable
assignContainer
in class Schedulable
public boolean hasContainerForNode(org.apache.hadoop.yarn.api.records.Priority prio, FSSchedulerNode node)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |