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

QueueCapacities.setAbsoluteCapacity介绍

暂无

代码示例

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

public void setAbsoluteCapacity(float absoluteCapacity) {
 queueCapacities.setAbsoluteCapacity(absoluteCapacity);
}

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

public void setAbsoluteCapacity(String nodeLabel, float absoluteCapacity) {
 queueCapacities.setAbsoluteCapacity(nodeLabel, absoluteCapacity);
}

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

public void setAbsoluteCapacity(float absoluteCapacity) {
 queueCapacities.setAbsoluteCapacity(absoluteCapacity);
}

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

public void setAbsoluteCapacity(float absoluteCapacity) {
 queueCapacities.setAbsoluteCapacity(absoluteCapacity);
}

代码示例来源：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

private static void updateAbsoluteCapacitiesByNodeLabels(
  QueueCapacities queueCapacities, QueueCapacities parentQueueCapacities) {
 for (String label : queueCapacities.getExistingNodeLabels()) {
  float capacity = queueCapacities.getCapacity(label);
  if (capacity > 0f) {
   queueCapacities.setAbsoluteCapacity(
     label,
     capacity
       * (parentQueueCapacities == null ? 1 : parentQueueCapacities
         .getAbsoluteCapacity(label)));
  }
  float maxCapacity = queueCapacities.getMaximumCapacity(label);
  if (maxCapacity > 0f) {
   queueCapacities.setAbsoluteMaximumCapacity(
     label,
     maxCapacity
       * (parentQueueCapacities == null ? 1 : parentQueueCapacities
         .getAbsoluteMaximumCapacity(label)));
  }
 }
}

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

private static void updateAbsoluteCapacitiesByNodeLabels(
  QueueCapacities queueCapacities, QueueCapacities parentQueueCapacities) {
 for (String label : queueCapacities.getExistingNodeLabels()) {
  float capacity = queueCapacities.getCapacity(label);
  if (capacity > 0f) {
   queueCapacities.setAbsoluteCapacity(
     label,
     capacity
       * (parentQueueCapacities == null ? 1 : parentQueueCapacities
         .getAbsoluteCapacity(label)));
  }
  float maxCapacity = queueCapacities.getMaximumCapacity(label);
  if (maxCapacity > 0f) {
   queueCapacities.setAbsoluteMaximumCapacity(
     label,
     maxCapacity
       * (parentQueueCapacities == null ? 1 : parentQueueCapacities
         .getAbsoluteMaximumCapacity(label)));
  }
 }
}

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

private static void updateAbsoluteCapacitiesByNodeLabels(
  QueueCapacities queueCapacities, QueueCapacities parentQueueCapacities) {
 for (String label : queueCapacities.getExistingNodeLabels()) {
  float capacity = queueCapacities.getCapacity(label);
  if (capacity > 0f) {
   queueCapacities.setAbsoluteCapacity(
     label,
     capacity
       * (parentQueueCapacities == null ? 1 : parentQueueCapacities
         .getAbsoluteCapacity(label)));
  }
  float maxCapacity = queueCapacities.getMaximumCapacity(label);
  if (maxCapacity > 0f) {
   queueCapacities.setAbsoluteMaximumCapacity(
     label,
     maxCapacity
       * (parentQueueCapacities == null ? 1 : parentQueueCapacities
         .getAbsoluteMaximumCapacity(label)));
  }
 }
}

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

parseResourceFromString(values[0].trim())) + epsilon;
Resource pending = parseResourceFromString(values[3].trim());
qc.setAbsoluteCapacity(partitionName, absGuaranteed);
qc.setAbsoluteMaximumCapacity(partitionName, absMax);
qc.setAbsoluteUsedCapacity(partitionName, absUsed);

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

QueueCapacities rootQc = new QueueCapacities(true);
rootQc.setAbsoluteUsedCapacity(Resources.divide(rc, tot, used[0], tot));
rootQc.setAbsoluteCapacity(Resources.divide(rc, tot, abs[0], tot));
rootQc.setAbsoluteMaximumCapacity(maxCap[0] / (float) tot.getMemorySize());
when(root.getQueueCapacities()).thenReturn(rootQc);
 qc.setAbsoluteCapacity(Resources.divide(rc, tot, abs[i], tot));
 qc.setAbsoluteMaximumCapacity(maxCap[i] / (float) tot.getMemorySize());
 when(q.getQueueCapacities()).thenReturn(qc);

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

private void mergeCapacities(QueueCapacities capacities) {
 for ( String nodeLabel : capacities.getExistingNodeLabels()) {
  queueCapacities.setCapacity(nodeLabel,
    capacities.getCapacity(nodeLabel));
  queueCapacities.setAbsoluteCapacity(nodeLabel, capacities
    .getAbsoluteCapacity(nodeLabel));
  queueCapacities.setMaximumCapacity(nodeLabel, capacities
    .getMaximumCapacity(nodeLabel));
  queueCapacities.setAbsoluteMaximumCapacity(nodeLabel, capacities
    .getAbsoluteMaximumCapacity(nodeLabel));
  Resource resourceByLabel = labelManager.getResourceByLabel(nodeLabel,
    csContext.getClusterResource());
  getQueueResourceQuotas().setEffectiveMinResource(nodeLabel,
    Resources.multiply(resourceByLabel,
      queueCapacities.getAbsoluteCapacity(nodeLabel)));
  getQueueResourceQuotas().setEffectiveMaxResource(nodeLabel,
    Resources.multiply(resourceByLabel, queueCapacities
      .getAbsoluteMaximumCapacity(nodeLabel)));
 }
}

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

childQueue.getQueueCapacities().setAbsoluteCapacity(label,
  (float) childQueue.getQueueCapacities().getCapacity()
    / getQueueCapacities().getAbsoluteCapacity(label));

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

queueResourceQuotas.setEffectiveMinResource(label, resourceByLabel);
queueResourceQuotas.setEffectiveMaxResource(label, resourceByLabel);
queueCapacities.setAbsoluteCapacity(label, 1.0f);