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

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

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

QueueCapacities.setUsedCapacity介绍

暂无

代码示例

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

@Override
public synchronized void setUsedCapacity(float usedCapacity) {
 queueCapacities.setUsedCapacity(usedCapacity);
}

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

@Override
public synchronized void setUsedCapacity(float usedCapacity) {
 queueCapacities.setUsedCapacity(usedCapacity);
}

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

private List<CSQueue> mockCSQueues(String[] queueNames, int[] priorities,
  float[] utilizations, float[] absCapacities, String partition) {
 // sanity check
 assert queueNames != null && priorities != null && utilizations != null
   && queueNames.length > 0 && queueNames.length == priorities.length
   && priorities.length == utilizations.length;
 List<CSQueue> list = new ArrayList<>();
 for (int i = 0; i < queueNames.length; i++) {
  CSQueue q = mock(CSQueue.class);
  when(q.getQueueName()).thenReturn(queueNames[i]);
  QueueCapacities qc = new QueueCapacities(false);
  qc.setAbsoluteCapacity(partition, absCapacities[i]);
  qc.setUsedCapacity(partition, utilizations[i]);
  when(q.getQueueCapacities()).thenReturn(qc);
  when(q.getPriority()).thenReturn(Priority.newInstance(priorities[i]));
  QueueResourceQuotas qr = new QueueResourceQuotas();
  when(q.getQueueResourceQuotas()).thenReturn(qr);
  list.add(q);
 }
 return list;
}

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

qc.setAbsoluteMaximumCapacity(partitionName, absMax);
qc.setAbsoluteUsedCapacity(partitionName, absUsed);
qc.setUsedCapacity(partitionName, used);
qr.setEffectiveMaxResource(parseResourceFromString(values[1].trim()));
qr.setEffectiveMinResource(parseResourceFromString(values[0].trim()));

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

queueCapacities.setUsedCapacity(nodePartition, usedCapacity);
queueCapacities.setReservedCapacity(nodePartition, reservedCapacity);
queueCapacities

相关文章