@InterfaceAudience.Private @InterfaceStability.Unstable public class FSParentQueue extends FSQueue
parent, policy, recordFactory
Constructor and Description |
---|
FSParentQueue(String name,
QueueManager queueMgr,
FairScheduler scheduler,
FSParentQueue parent) |
Modifier and Type | Method and Description |
---|---|
void |
addChildQueue(FSQueue child) |
Resource |
assignContainer(FSSchedulerNode node)
Assign a container on this node if possible, and return the amount of
resources assigned.
|
Collection<FSQueue> |
getChildQueues()
Gets the children of this queue, if any.
|
Resource |
getDemand()
Maximum number of resources required by this Schedulable.
|
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 |
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 FSParentQueue(String name, QueueManager queueMgr, FairScheduler scheduler, FSParentQueue parent)
public void addChildQueue(FSQueue child)
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 List<QueueUserACLInfo> getQueueUserAclInfo(UserGroupInformation user)
Queue
user
.user
- usernamepublic Resource assignContainer(FSSchedulerNode node)
Schedulable
assignContainer
in class Schedulable
public Collection<FSQueue> getChildQueues()
FSQueue
getChildQueues
in class FSQueue
public void setPolicy(SchedulingPolicy policy) throws AllocationConfigurationException
setPolicy
in class FSQueue
AllocationConfigurationException
Copyright © 2013 Apache Software Foundation. All rights reserved.