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

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

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

QueueCapacities.setCapacity介绍

暂无

代码示例

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

public void setCapacity(float capacity) {
 queueCapacities.setCapacity(capacity);
}

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

public void setCapacity(float capacity) {
 queueCapacities.setCapacity(capacity);
}

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

public void setCapacity(float capacity) {
 queueCapacities.setCapacity(capacity);
}

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

public void setCapacity(String nodeLabel, float capacity) {
 queueCapacities.setCapacity(nodeLabel, capacity);
}

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

private static void loadCapacitiesByLabelsFromConf(String queuePath,
  QueueCapacities queueCapacities, CapacitySchedulerConfiguration csConf) {
 queueCapacities.clearConfigurableFields();
 Set<String> configuredNodelabels =
   csConf.getConfiguredNodeLabels(queuePath);
 for (String label : configuredNodelabels) {
  if (label.equals(CommonNodeLabelsManager.NO_LABEL)) {
   queueCapacities.setCapacity(CommonNodeLabelsManager.NO_LABEL,
     csConf.getNonLabeledQueueCapacity(queuePath) / 100);
   queueCapacities.setMaximumCapacity(CommonNodeLabelsManager.NO_LABEL,
     csConf.getNonLabeledQueueMaximumCapacity(queuePath) / 100);
  } else {
   queueCapacities.setCapacity(label,
     csConf.getLabeledQueueCapacity(queuePath, label) / 100);
   queueCapacities.setMaximumCapacity(label,
     csConf.getLabeledQueueMaximumCapacity(queuePath, label) / 100);
  }
 }
}

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

private static void loadCapacitiesByLabelsFromConf(String queuePath,
  QueueCapacities queueCapacities, CapacitySchedulerConfiguration csConf) {
 queueCapacities.clearConfigurableFields();
 Set<String> configuredNodelabels =
   csConf.getConfiguredNodeLabels(queuePath);
 for (String label : configuredNodelabels) {
  if (label.equals(CommonNodeLabelsManager.NO_LABEL)) {
   queueCapacities.setCapacity(CommonNodeLabelsManager.NO_LABEL,
     csConf.getNonLabeledQueueCapacity(queuePath) / 100);
   queueCapacities.setMaximumCapacity(CommonNodeLabelsManager.NO_LABEL,
     csConf.getNonLabeledQueueMaximumCapacity(queuePath) / 100);
  } else {
   queueCapacities.setCapacity(label,
     csConf.getLabeledQueueCapacity(queuePath, label) / 100);
   queueCapacities.setMaximumCapacity(label,
     csConf.getLabeledQueueMaximumCapacity(queuePath, label) / 100);
  }
 }
}

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

private static void loadCapacitiesByLabelsFromConf(String queuePath,
  QueueCapacities queueCapacities, CapacitySchedulerConfiguration csConf) {
 queueCapacities.clearConfigurableFields();
 Set<String> configuredNodelabels =
   csConf.getConfiguredNodeLabels(queuePath);
 for (String label : configuredNodelabels) {
  if (label.equals(CommonNodeLabelsManager.NO_LABEL)) {
   queueCapacities.setCapacity(label,
     csConf.getNonLabeledQueueCapacity(queuePath) / 100);
   queueCapacities.setMaximumCapacity(label,
     csConf.getNonLabeledQueueMaximumCapacity(queuePath) / 100);
   queueCapacities.setMaxAMResourcePercentage(
     label,
     csConf.getMaximumAMResourcePercentPerPartition(queuePath, label));
  } else {
   queueCapacities.setCapacity(label,
     csConf.getLabeledQueueCapacity(queuePath, label) / 100);
   queueCapacities.setMaximumCapacity(label,
     csConf.getLabeledQueueMaximumCapacity(queuePath, label) / 100);
   queueCapacities.setMaxAMResourcePercentage(label,
     csConf.getMaximumAMResourcePercentPerPartition(queuePath, label));
  }
 }
}

代码示例来源: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().setCapacity(label,
  rc.divide(clusterResource,
    childQueue.getQueueResourceQuotas().getEffectiveMinResource(label),

相关文章