@InterfaceStability.Evolving
@InterfaceAudience.LimitedPrivate(value="yarn")
public interface Queue
Modifier and Type | Interface and Description |
---|---|
static class |
Queue.QueueLabelPolicy |
Modifier and Type | Field and Description |
---|---|
static String |
LABEL_NONE |
Modifier and Type | Method and Description |
---|---|
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
|
ActiveUsersManager |
getActiveUsersManager() |
String |
getDefaultNodeLabelExpression()
Get default label expression of this queue.
|
net.java.dev.eval.Expression |
getLabel() |
Queue.QueueLabelPolicy |
getLabelPolicy() |
QueueMetrics |
getMetrics()
Get the queue metrics
|
org.apache.hadoop.yarn.api.records.QueueInfo |
getQueueInfo(boolean includeChildQueues,
boolean recursive)
Get queue information
|
String |
getQueueName()
Get the queue name
|
List<org.apache.hadoop.yarn.api.records.QueueUserACLInfo> |
getQueueUserAclInfo(org.apache.hadoop.security.UserGroupInformation user)
Get queue ACLs for given
user . |
boolean |
hasAccess(org.apache.hadoop.yarn.api.records.QueueACL acl,
org.apache.hadoop.security.UserGroupInformation user) |
void |
recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource,
SchedulerApplicationAttempt schedulerAttempt,
RMContainer rmContainer)
Recover the state of the queue for a given container.
|
static final String LABEL_NONE
String getQueueName()
QueueMetrics getMetrics()
org.apache.hadoop.yarn.api.records.QueueInfo getQueueInfo(boolean includeChildQueues, boolean recursive)
includeChildQueues
- include child queues?recursive
- recursively get child queue information?List<org.apache.hadoop.yarn.api.records.QueueUserACLInfo> getQueueUserAclInfo(org.apache.hadoop.security.UserGroupInformation user)
user
.user
- usernameboolean hasAccess(org.apache.hadoop.yarn.api.records.QueueACL acl, org.apache.hadoop.security.UserGroupInformation user)
ActiveUsersManager getActiveUsersManager()
void recoverContainer(org.apache.hadoop.yarn.api.records.Resource clusterResource, SchedulerApplicationAttempt schedulerAttempt, RMContainer rmContainer)
clusterResource
- the resource of the clusterschedulerAttempt
- the application for which the container was allocatedrmContainer
- the container that was recovered.Set<String> getAccessibleNodeLabels()
String getDefaultNodeLabelExpression()
Queue.QueueLabelPolicy getLabelPolicy()
net.java.dev.eval.Expression getLabel()
Copyright © 2015 Apache Software Foundation. All Rights Reserved.