Queue.QueueLabelPolicy
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.yarn.security.YarnAuthorizationProvider |
authorizer |
protected CapacitySchedulerContext |
csContext |
protected org.apache.hadoop.yarn.security.PrivilegedEntity |
queueEntity |
LABEL_NONE
Constructor and Description |
---|
AbstractCSQueue(CapacitySchedulerContext cs,
String queueName,
CSQueue parent,
CSQueue old) |
Modifier and Type | Method and Description |
---|---|
float |
getAbsoluteCapacity()
Get capacity of the parent of the queue as a function of the
cumulative capacity in the cluster.
|
float |
getAbsoluteMaximumCapacity()
Get maximum-capacity of the queue as a funciton of the cumulative capacity
of the cluster.
|
float |
getAbsoluteUsedCapacity()
Get the current absolute used capacity of the queue
relative to the entire cluster.
|
Set<String> |
getAccessibleNodeLabels()
Get labels can be accessed of this queue
labels={*}, means this queue can access any label
labels={ }, means this queue cannot access any label except node without label
labels={a, b, c} means this queue can access a or b or c
|
Map<org.apache.hadoop.yarn.security.AccessType,org.apache.hadoop.security.authorize.AccessControlList> |
getACLs() |
float |
getCapacity()
Get the configured capacity of the queue.
|
protected org.apache.hadoop.yarn.api.records.Resource |
getCurrentResourceLimit(org.apache.hadoop.yarn.api.records.Resource clusterResource,
ResourceLimits currentResourceLimits) |
String |
getDefaultNodeLabelExpression()
Get default label expression of this queue.
|
org.apache.hadoop.yarn.api.records.Resource |
getMaximumAllocation() |
float |
getMaximumCapacity()
Get the configured maximum-capacity of the queue.
|
QueueMetrics |
getMetrics()
Get the queue metrics
|
org.apache.hadoop.yarn.api.records.Resource |
getMinimumAllocation() |
int |
getNumContainers() |
CSQueue |
getParent()
Get the parent
Queue . |
boolean |
getPreemptionDisabled()
Check whether disable_preemption property is set for this queue
|
org.apache.hadoop.yarn.security.PrivilegedEntity |
getPrivilegedEntity() |
QueueCapacities |
getQueueCapacities()
Get QueueCapacities of this queue
|
protected org.apache.hadoop.yarn.api.records.QueueInfo |
getQueueInfo() |
String |
getQueueName()
Get the queue name.
|
ResourceUsage |
getQueueResourceUsage()
Get ResourceUsage of this queue
|
boolean |
getReservationContinueLooking() |
org.apache.hadoop.yarn.api.records.QueueState |
getState()
Get the current run-state of the queue
|
float |
getUsedCapacity()
Get the current used capacity of nodes without label(s) of the queue
and it's children (if any).
|
org.apache.hadoop.yarn.api.records.Resource |
getUsedResources()
Get the currently utilized resources which allocated at nodes without any
labels in the cluster by the queue and children (if any).
|
boolean |
hasAccess(org.apache.hadoop.yarn.api.records.QueueACL acl,
org.apache.hadoop.security.UserGroupInformation user)
Check if the
user has permission to perform the operation |
protected void |
releaseResource(org.apache.hadoop.yarn.api.records.Resource clusterResource,
org.apache.hadoop.yarn.api.records.Resource resource,
Set<String> nodeLabels) |
void |
setAbsoluteUsedCapacity(float absUsedCapacity)
Set absolute used capacity of the queue.
|
void |
setParent(CSQueue newParentQueue)
Set the parent
Queue . |
protected void |
setupConfigurableCapacities() |
void |
setUsedCapacity(float usedCapacity)
Set used capacity of the queue.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
assignContainers, attachContainer, collectSchedulerApplications, completedContainer, detachContainer, finishApplication, finishApplicationAttempt, getActiveUsersManager, getChildQueues, getNumApplications, getQueuePath, reinitialize, submitApplication, submitApplicationAttempt, updateClusterResource
getLabel, getLabelPolicy, getQueueInfo, getQueueUserAclInfo, recoverContainer
protected final org.apache.hadoop.yarn.security.PrivilegedEntity queueEntity
protected CapacitySchedulerContext csContext
protected org.apache.hadoop.yarn.security.YarnAuthorizationProvider authorizer
public AbstractCSQueue(CapacitySchedulerContext cs, String queueName, CSQueue parent, CSQueue old) throws IOException
IOException
protected void setupConfigurableCapacities()
public float getCapacity()
CSQueue
getCapacity
in interface CSQueue
public float getAbsoluteCapacity()
CSQueue
getAbsoluteCapacity
in interface CSQueue
public float getAbsoluteMaximumCapacity()
CSQueue
getAbsoluteMaximumCapacity
in interface CSQueue
public float getAbsoluteUsedCapacity()
CSQueue
getAbsoluteUsedCapacity
in interface CSQueue
public float getMaximumCapacity()
CSQueue
getMaximumCapacity
in interface CSQueue
public float getUsedCapacity()
CSQueue
getUsedCapacity
in interface CSQueue
public org.apache.hadoop.yarn.api.records.Resource getUsedResources()
CSQueue
getUsedResources
in interface CSQueue
public int getNumContainers()
public org.apache.hadoop.yarn.api.records.QueueState getState()
CSQueue
public QueueMetrics getMetrics()
Queue
getMetrics
in interface Queue
public String getQueueName()
CSQueue
getQueueName
in interface CSQueue
getQueueName
in interface Queue
public org.apache.hadoop.yarn.security.PrivilegedEntity getPrivilegedEntity()
public CSQueue getParent()
CSQueue
Queue
.public void setParent(CSQueue newParentQueue)
CSQueue
Queue
.public Set<String> getAccessibleNodeLabels()
Queue
getAccessibleNodeLabels
in interface Queue
public boolean hasAccess(org.apache.hadoop.yarn.api.records.QueueACL acl, org.apache.hadoop.security.UserGroupInformation user)
CSQueue
user
has permission to perform the operationpublic void setUsedCapacity(float usedCapacity)
CSQueue
setUsedCapacity
in interface CSQueue
usedCapacity
- used capacity of the queuepublic void setAbsoluteUsedCapacity(float absUsedCapacity)
CSQueue
setAbsoluteUsedCapacity
in interface CSQueue
absUsedCapacity
- absolute used capacity of the queuepublic String getDefaultNodeLabelExpression()
Queue
getDefaultNodeLabelExpression
in interface Queue
protected org.apache.hadoop.yarn.api.records.QueueInfo getQueueInfo()
@InterfaceAudience.Private public org.apache.hadoop.yarn.api.records.Resource getMaximumAllocation()
@InterfaceAudience.Private public org.apache.hadoop.yarn.api.records.Resource getMinimumAllocation()
protected void releaseResource(org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource resource, Set<String> nodeLabels)
@InterfaceAudience.Private public boolean getReservationContinueLooking()
@InterfaceAudience.Private public Map<org.apache.hadoop.yarn.security.AccessType,org.apache.hadoop.security.authorize.AccessControlList> getACLs()
@InterfaceAudience.Private public boolean getPreemptionDisabled()
CSQueue
getPreemptionDisabled
in interface CSQueue
@InterfaceAudience.Private public QueueCapacities getQueueCapacities()
CSQueue
getQueueCapacities
in interface CSQueue
@InterfaceAudience.Private public ResourceUsage getQueueResourceUsage()
CSQueue
getQueueResourceUsage
in interface CSQueue
protected org.apache.hadoop.yarn.api.records.Resource getCurrentResourceLimit(org.apache.hadoop.yarn.api.records.Resource clusterResource, ResourceLimits currentResourceLimits)
Copyright © 2017 Apache Software Foundation. All Rights Reserved.