org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager.removeQueue()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(3.2k)|赞(0)|评价(0)|浏览(76)

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

QueueManager.removeQueue介绍

[英]Remove a queue and all its descendents.
[中]删除队列及其所有后代。

代码示例

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

/**
 * Remove the queue if it and its descendents are all empty.
 * @param queue
 * @return true if removed, false otherwise
 */
private boolean removeQueueIfEmpty(FSQueue queue) {
 if (isEmpty(queue)) {
  removeQueue(queue);
  return true;
 }
 return false;
}

代码示例来源: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: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

/**
 * Remove the queue if it and its descendents are all empty.
 * @param queue
 * @return true if removed, false otherwise
 */
private boolean removeQueueIfEmpty(FSQueue queue) {
 if (isEmpty(queue)) {
  removeQueue(queue);
  return true;
 }
 return false;
}

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

/**
 * Remove the queue if it and its descendents are all empty.
 * @param queue
 * @return true if removed, false otherwise
 */
private boolean removeQueueIfEmpty(FSQueue queue) {
 if (isEmpty(queue)) {
  removeQueue(queue);
  return true;
 }
 return false;
}

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

/**
 * Remove a queue and all its descendents.
 */
private void removeQueue(FSQueue queue) {
 if (queue instanceof FSLeafQueue) {
  leafQueues.remove(queue);
 } else {
  List<FSQueue> childQueues = queue.getChildQueues();
  while (!childQueues.isEmpty()) {
   removeQueue(childQueues.get(0));
  }
 }
 queues.remove(queue.getName());
 queue.getParent().getChildQueues().remove(queue);
}

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

/**
 * Remove a queue and all its descendents.
 */
private void removeQueue(FSQueue queue) {
 if (queue instanceof FSLeafQueue) {
  leafQueues.remove(queue);
 } else {
  List<FSQueue> childQueues = queue.getChildQueues();
  while (!childQueues.isEmpty()) {
   removeQueue(childQueues.get(0));
  }
 }
 queues.remove(queue.getName());
 queue.getParent().getChildQueues().remove(queue);
}

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

/**
 * Remove a queue and all its descendents.
 */
private void removeQueue(FSQueue queue) {
 synchronized (queues) {
  if (queue instanceof FSLeafQueue) {
   leafQueues.remove(queue);
  } else {
   for (FSQueue childQueue:queue.getChildQueues()) {
    removeQueue(childQueue);
   }
  }
  queues.remove(queue.getName());
  FSParentQueue parent = queue.getParent();
  parent.removeChildQueue(queue);
 }
}

相关文章