@InterfaceAudience.Private @InterfaceStability.Unstable public class FSLeafQueue extends FSQueue
parent, policy, recordFactory
Constructor and Description |
---|
FSLeafQueue(String name,
QueueManager queueMgr,
FairScheduler scheduler,
FSParentQueue parent) |
Modifier and Type | Method and Description |
---|---|
void |
addApp(FSSchedulerApp app) |
Resource |
assignContainer(FSSchedulerNode node)
Assign a container on this node if possible, and return the amount of
resources assigned.
|
Collection<AppSchedulable> |
getAppSchedulables() |
Collection<FSQueue> |
getChildQueues()
Gets the children of this queue, if any.
|
Resource |
getDemand()
Maximum number of resources required by this Schedulable.
|
long |
getLastTimeAtHalfFairShare() |
long |
getLastTimeAtMinShare() |
List<QueueUserACLInfo> |
getQueueUserAclInfo(UserGroupInformation user)
Get queue ACLs for given
user . |
Resource |
getResourceUsage()
Get the aggregate amount of resources consumed by the schedulable.
|
void |
recomputeShares()
Recomputes the shares for all child queues and applications based on this
queue's current share
|
void |
removeApp(FSSchedulerApp app) |
void |
setLastTimeAtHalfFairShare(long lastTimeAtHalfFairShare) |
void |
setLastTimeAtMinShare(long lastTimeAtMinShare) |
void |
setPolicy(SchedulingPolicy policy) |
void |
updateDemand()
Refresh the Schedulable's demand and those of its children if any.
|
assignContainerPreCheck, getMaxShare, getMetrics, getMinShare, getName, getPolicy, getPriority, getQueueAcls, getQueueInfo, getQueueName, getStartTime, getWeights, hasAccess, setFairShare, throwPolicyDoesnotApplyException
getFairShare, toString
public FSLeafQueue(String name, QueueManager queueMgr, FairScheduler scheduler, FSParentQueue parent)
public void addApp(FSSchedulerApp app)
public void removeApp(FSSchedulerApp app)
public Collection<AppSchedulable> getAppSchedulables()
public void setPolicy(SchedulingPolicy policy) throws AllocationConfigurationException
setPolicy
in class FSQueue
AllocationConfigurationException
public void recomputeShares()
FSQueue
recomputeShares
in class FSQueue
public Resource getDemand()
Schedulable
getDemand
in class Schedulable
public Resource getResourceUsage()
Schedulable
getResourceUsage
in class Schedulable
public void updateDemand()
Schedulable
updateDemand
in class Schedulable
public Resource assignContainer(FSSchedulerNode node)
Schedulable
assignContainer
in class Schedulable
public Collection<FSQueue> getChildQueues()
FSQueue
getChildQueues
in class FSQueue
public List<QueueUserACLInfo> getQueueUserAclInfo(UserGroupInformation user)
Queue
user
.user
- usernamepublic long getLastTimeAtMinShare()
public void setLastTimeAtMinShare(long lastTimeAtMinShare)
public long getLastTimeAtHalfFairShare()
public void setLastTimeAtHalfFairShare(long lastTimeAtHalfFairShare)
Copyright © 2013 Apache Software Foundation. All rights reserved.