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

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

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

Queue.getQueueInfo介绍

[英]Get queue information
[中]获取队列信息

代码示例

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

@Override
public QueueInfo getQueueInfo(String queueName,
  boolean includeChildQueues, boolean recursive) {
 return DEFAULT_QUEUE.getQueueInfo(false, false);
}

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

@Override
public QueueInfo getQueueInfo(String queueName,
  boolean includeChildQueues, boolean recursive) {
 return DEFAULT_QUEUE.getQueueInfo(false, false);
}

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

@Override
public QueueInfo getQueueInfo(String queueName,
  boolean includeChildQueues, boolean recursive) {
 return DEFAULT_QUEUE.getQueueInfo(false, false);
}

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

private Queue createQueue(String name, Queue parent, float capacity) {
 QueueMetrics metrics = QueueMetrics.forQueue(name, parent, false, conf);
 QueueInfo queueInfo = QueueInfo.newInstance(name, capacity, 1.0f, 0, null,
   null, QueueState.RUNNING, null, "", null, false, null, false);
 ActiveUsersManager activeUsersManager = new ActiveUsersManager(metrics);
 Queue queue = mock(Queue.class);
 when(queue.getMetrics()).thenReturn(metrics);
 when(queue.getAbstractUsersManager()).thenReturn(activeUsersManager);
 when(queue.getQueueInfo(false, false)).thenReturn(queueInfo);
 return queue;
}

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

float clusterUsagePerc = 0.0f;
if (!calc.isInvalidDivisor(cluster)) {
 float queueCapacityPerc = queue.getQueueInfo(false, false)
   .getCapacity();
 if (queueCapacityPerc != 0) {

相关文章