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

QueueCapacities.getUsedCapacity介绍

暂无

代码示例

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

@Override
public float getUsedCapacity() {
 return queueCapacities.getUsedCapacity();
}

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

@Override
public synchronized float getUsedCapacity() {
 return queueCapacities.getUsedCapacity();
}

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

@Override
public synchronized float getUsedCapacity() {
 return queueCapacities.getUsedCapacity();
}

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

private CSAssignment allocateContainersOnMultiNodes(
  CandidateNodeSet<FiCaSchedulerNode> candidates) {
 // When this time look at multiple nodes, try schedule if the
 // partition has any available resource or killable resource
 if (getRootQueue().getQueueCapacities().getUsedCapacity(
   candidates.getPartition()) >= 1.0f
   && preemptionManager.getKillableResource(
   CapacitySchedulerConfiguration.ROOT, candidates.getPartition())
   == Resources.none()) {
  if (LOG.isDebugEnabled()) {
   LOG.debug("This node or this node partition doesn't have available or"
     + "killable resource");
  }
  return null;
 }
 return allocateOrReserveNewContainers(candidates, false);
}

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

float used1 = q1.getQueueCapacities().getUsedCapacity(p);
float used2 = q2.getQueueCapacities().getUsedCapacity(p);

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

private void checkUsedCapacity(MockRM rm, String queueName, int capacity,
  int total, String label) {
 float epsillon = 0.0001f;
 CapacityScheduler scheduler = (CapacityScheduler) rm.getResourceScheduler();
 CSQueue queue = scheduler.getQueue(queueName);
 Assert.assertEquals((float)capacity/total,
   queue.getQueueCapacities().getUsedCapacity(label), epsillon);
}

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

" [= (int)(maxApplications * (userLimit / 100.0f) * " +
"userLimitFactor) ]" + "\n" +
"usedCapacity = " + queueCapacities.getUsedCapacity() +
" [= usedResourcesMemory / " +
"(clusterResourceMemory * absoluteCapacity)]" + "\n" +

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

" [= (int)(maxApplications * (userLimit / 100.0f) * " +
"userLimitFactor) ]" + "\n" +
"usedCapacity = " + queueCapacities.getUsedCapacity() +
" [= usedResourcesMemory / " +
"(clusterResourceMemory * absoluteCapacity)]" + "\n" +

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

+ " [= (int)(maxApplications * (userLimit / 100.0f) * "
+ "userLimitFactor) ]" + "\n" + "usedCapacity = "
+ queueCapacities.getUsedCapacity() + " [= usedResourcesMemory / "
+ "(clusterResourceMemory * absoluteCapacity)]" + "\n"
+ "absoluteUsedCapacity = " + absoluteUsedCapacity

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

private void checkQueueUsedCapacity(String queueName, CapacityScheduler cs,
  String nodePartition, float usedCapacity, float absoluteUsedCapacity) {
 float epsilon = 1e-6f;
 CSQueue queue = cs.getQueue(queueName);
 Assert.assertNotNull("Failed to get queue=" + queueName, queue);
 Assert.assertEquals(usedCapacity, queue.getQueueCapacities()
   .getUsedCapacity(nodePartition), epsilon);
 Assert.assertEquals(absoluteUsedCapacity, queue.getQueueCapacities()
   .getAbsoluteUsedCapacity(nodePartition), epsilon);
}

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

if (leafQueue.getQueueCapacities().getUsedCapacity(partition) < context
  .getMinimumThresholdForIntraQueuePreemption()) {
 continue;

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

float maxAMLimitPercentage;
for (String partitionName : capacities.getExistingNodeLabels()) {
 usedCapacity = capacities.getUsedCapacity(partitionName) * 100;
 capacity = capacities.getCapacity(partitionName) * 100;
 maxCapacity = capacities.getMaximumCapacity(partitionName);

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

queueCapacities.getUsedCapacity(RMNodeLabelsManager.NO_LABEL));
queueMetrics.setAbsoluteUsedCapacity(nodePartition,
  queueCapacities.getAbsoluteUsedCapacity(