本文整理了Java中org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager.removeQueueIfEmpty
方法的一些代码示例,展示了QueueManager.removeQueueIfEmpty
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueueManager.removeQueueIfEmpty
方法的具体详情如下:
包路径:org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager
类名称:QueueManager
方法名:removeQueueIfEmpty
[英]Remove the queue if it and its descendents are all empty.
[中]
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager
return removeQueueIfEmpty(queue);
} else {
if (queueType == FSQueueType.PARENT) {
return removeQueueIfEmpty(queue);
FSQueue prefixQueue = queues.get(prefixString);
if (prefixQueue != null && prefixQueue instanceof FSLeafQueue) {
return removeQueueIfEmpty(prefixQueue);
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager
return removeQueueIfEmpty(queue);
} else {
if (queueType == FSQueueType.PARENT) {
return removeQueueIfEmpty(queue);
FSQueue prefixQueue = queues.get(prefixString);
if (prefixQueue != null && prefixQueue instanceof FSLeafQueue) {
return removeQueueIfEmpty(prefixQueue);
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager
return Optional.of(removeQueueIfEmpty(queue));
} else {
if (queueType == FSQueueType.PARENT) {
return Optional.of(removeQueueIfEmpty(queue));
FSQueue prefixQueue = queues.get(prefixString);
if (prefixQueue != null && prefixQueue instanceof FSLeafQueue) {
return Optional.of(removeQueueIfEmpty(prefixQueue));
代码示例来源: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);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!