本文整理了Java中org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager.getQueues方法的一些代码示例，展示了QueueManager.getQueues的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueueManager.getQueues方法的具体详情如下：
包路径：org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager
类名称：QueueManager
方法名：getQueues

QueueManager.getQueues介绍

[英]Get a collection of all queues
[中]获取所有队列的集合

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Override
public Set<String> getPlanQueues() throws YarnException {
 Set<String> planQueues = new HashSet<String>();
 for (FSQueue fsQueue : queueMgr.getQueues()) {
  String queueName = fsQueue.getName();
  if (allocConf.isReservable(queueName)) {
   planQueues.add(queueName);
  }
 }
 return planQueues;
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
public Set<String> getPlanQueues() throws YarnException {
 Set<String> planQueues = new HashSet<String>();
 for (FSQueue fsQueue : queueMgr.getQueues()) {
  String queueName = fsQueue.getName();
  if (allocConf.isReservable(queueName)) {
   planQueues.add(queueName);
  }
 }
 return planQueues;
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
public Set<String> getPlanQueues() throws YarnException {
 Set<String> planQueues = new HashSet<String>();
 for (FSQueue fsQueue : queueMgr.getQueues()) {
  String queueName = fsQueue.getName();
  if (allocConf.isReservable(queueName)) {
   planQueues.add(queueName);
  }
 }
 return planQueues;
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

/**
 * Removes all empty dynamic queues (including empty dynamic parent queues).
 */
public void removeEmptyDynamicQueues() {
 synchronized (queues) {
  Set<FSParentQueue> parentQueuesToCheck = new HashSet<>();
  for (FSQueue queue : getQueues()) {
   if (queue.isDynamic() && queue.getChildQueues().isEmpty()) {
    boolean removed = removeQueueIfEmpty(queue);
    if (removed && queue.getParent().isDynamic()) {
     parentQueuesToCheck.add(queue.getParent());
    }
   }
  }
  while (!parentQueuesToCheck.isEmpty()) {
   FSParentQueue queue = parentQueuesToCheck.iterator().next();
   if (queue.getChildQueues().isEmpty()) {
    removeQueue(queue);
    if (queue.getParent().isDynamic()) {
     parentQueuesToCheck.add(queue.getParent());
    }
   }
   parentQueuesToCheck.remove(queue);
  }
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

/**
 * After reloading the allocation config, the max resource settings for any
 * ad hoc queues will be missing. This method goes through the queue manager's
 * queue list and adds back the max resources settings for any ad hoc queues.
 * Note that the new max resource settings will be based on the new config.
 * The old settings are lost.
 */
private void applyChildDefaults() {
 Collection<FSQueue> queues = queueMgr.getQueues();
 Set<String> configuredLeafQueues =
   allocConf.getConfiguredQueues().get(FSQueueType.LEAF);
 Set<String> configuredParentQueues =
   allocConf.getConfiguredQueues().get(FSQueueType.PARENT);
 for (FSQueue queue : queues) {
  // If the queue is ad hoc and not root, apply the child defaults
  if ((queue.getParent() != null) &&
    !configuredLeafQueues.contains(queue.getName()) &&
    !configuredParentQueues.contains(queue.getName())) {
   ConfigurableResource max = queue.getParent().
     getMaxChildQueueResource();
   if (max != null) {
    queue.setMaxShare(max);
   }
  }
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

resourceManager.start();
scheduler = (FairScheduler) resourceManager.getResourceScheduler();
for(FSQueue queue: scheduler.getQueueManager().getQueues()) {
 assertEquals(queue.getMetrics().getMaxApps(), Integer.MAX_VALUE);
 assertEquals(queue.getMetrics().getSchedulingPolicy(),