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

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

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

QueueCapacities.getCapacity介绍

暂无

代码示例

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

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

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

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

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

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

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

public void validateConfigurations(AutoCreatedLeafQueueConfig template)
  throws SchedulerDynamicEditException {
 QueueCapacities capacities = template.getQueueCapacities();
 for (String label : capacities.getExistingNodeLabels()) {
  float capacity = capacities.getCapacity(label);
  if (capacity < 0 || capacity > 1.0f) {
   throw new SchedulerDynamicEditException(
     "Capacity demand is not in the [0,1] range: " + capacity);
  }
 }
}

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

public String toString() {
 return queueName + ": " +
   "numChildQueue= " + childQueues.size() + ", " + 
   "capacity=" + queueCapacities.getCapacity() + ", " +  
   "absoluteCapacity=" + queueCapacities.getAbsoluteCapacity() + ", " +
   "usedResources=" + queueUsage.getUsed() + 
   "usedCapacity=" + getUsedCapacity() + ", " + 
   "numApps=" + getNumApplications() + ", " + 
   "numContainers=" + getNumContainers();
}

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

public String toString() {
 return queueName + ": " +
   "numChildQueue= " + childQueues.size() + ", " + 
   "capacity=" + queueCapacities.getCapacity() + ", " +  
   "absoluteCapacity=" + queueCapacities.getAbsoluteCapacity() + ", " +
   "usedResources=" + queueUsage.getUsed() + 
   "usedCapacity=" + getUsedCapacity() + ", " + 
   "numApps=" + getNumApplications() + ", " + 
   "numContainers=" + getNumContainers();
}

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

public String toString() {
 return queueName + ": " +
   "numChildQueue= " + childQueues.size() + ", " + 
   "capacity=" + queueCapacities.getCapacity() + ", " +  
   "absoluteCapacity=" + queueCapacities.getAbsoluteCapacity() + ", " +
   "usedResources=" + queueUsage.getUsed() + 
   "usedCapacity=" + getUsedCapacity() + ", " + 
   "numApps=" + getNumApplications() + ", " + 
   "numContainers=" + getNumContainers();
}

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

public String toString() {
 try {
  readLock.lock();
  return queueName + ": " + "capacity=" + queueCapacities.getCapacity()
    + ", " + "absoluteCapacity=" + queueCapacities.getAbsoluteCapacity()
    + ", " + "usedResources=" + queueUsage.getUsed() + ", "
    + "usedCapacity=" + getUsedCapacity() + ", " + "absoluteUsedCapacity="
    + getAbsoluteUsedCapacity() + ", " + "numApps=" + getNumApplications()
    + ", " + "numContainers=" + getNumContainers() + ", "
    + "effectiveMinResource=" +
    getEffectiveCapacity(CommonNodeLabelsManager.NO_LABEL) +
    " , effectiveMaxResource=" +
    getEffectiveMaxCapacity(CommonNodeLabelsManager.NO_LABEL);
 } finally {
  readLock.unlock();
 }
}

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

/**
 * Set maximum capacity
 * @param maximumCapacity new max capacity
 */
void setMaxCapacity(String nodeLabel, float maximumCapacity) {
 try {
  writeLock.lock();
  // Sanity check
  CSQueueUtils.checkMaxCapacity(getQueueName(),
    queueCapacities.getCapacity(nodeLabel), maximumCapacity);
  float absMaxCapacity = CSQueueUtils.computeAbsoluteMaximumCapacity(
    maximumCapacity, parent);
  CSQueueUtils.checkAbsoluteCapacity(getQueueName(),
    queueCapacities.getAbsoluteCapacity(nodeLabel), absMaxCapacity);
  queueCapacities.setMaximumCapacity(maximumCapacity);
  queueCapacities.setAbsoluteMaximumCapacity(absMaxCapacity);
 } finally {
  writeLock.unlock();
 }
}

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

public CapacitySchedulerInfo(final CSQueue parent, final NodeLabel nodeLabel) {
 String label = nodeLabel.getLabelName();
 QueueCapacities parentQueueCapacities = parent.getQueueCapacities();
 this.queueName = parent.getQueueName();
 this.usedCapacity = parent.getUsedCapacity(label) * 100;
 this.capacity = parentQueueCapacities.getCapacity(label) * 100;
 float max = parentQueueCapacities.getMaximumCapacity(label);
 if (max < EPSILON || max > 1f)
  max = 1f;
 this.maxCapacity = max * 100;
 queues = getQueues(parent, nodeLabel);
}

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

/**
 * Set maximum capacity - used only for testing.
 * @param maximumCapacity new max capacity
 */
void setMaxCapacity(float maximumCapacity) {
 try {
  writeLock.lock();
  // Sanity check
  CSQueueUtils.checkMaxCapacity(getQueueName(),
    queueCapacities.getCapacity(), maximumCapacity);
  float absMaxCapacity = CSQueueUtils.computeAbsoluteMaximumCapacity(
    maximumCapacity, parent);
  CSQueueUtils.checkAbsoluteCapacity(getQueueName(),
    queueCapacities.getAbsoluteCapacity(), absMaxCapacity);
  queueCapacities.setMaximumCapacity(maximumCapacity);
  queueCapacities.setAbsoluteMaximumCapacity(absMaxCapacity);
 } finally {
  writeLock.unlock();
 }
}

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

public CapacitySchedulerInfo(final CSQueue parent, final NodeLabel nodeLabel) {
 String label = nodeLabel.getLabelName();
 QueueCapacities parentQueueCapacities = parent.getQueueCapacities();
 this.queueName = parent.getQueueName();
 this.usedCapacity = parent.getUsedCapacity(label) * 100;
 this.capacity = parentQueueCapacities.getCapacity(label) * 100;
 float max = parentQueueCapacities.getMaximumCapacity(label);
 if (max < EPSILON || max > 1f)
  max = 1f;
 this.maxCapacity = max * 100;
 queues = getQueues(parent, nodeLabel);
}

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

public String toString() {
 return queueName + ": " + 
   "capacity=" + queueCapacities.getCapacity() + ", " + 
   "absoluteCapacity=" + queueCapacities.getAbsoluteCapacity() + ", " + 
   "usedResources=" + queueUsage.getUsed() +  ", " +
   "usedCapacity=" + getUsedCapacity() + ", " + 
   "absoluteUsedCapacity=" + getAbsoluteUsedCapacity() + ", " +
   "numApps=" + getNumApplications() + ", " + 
   "numContainers=" + getNumContainers();  
}

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

public String toString() {
 return queueName + ": " + 
   "capacity=" + queueCapacities.getCapacity() + ", " + 
   "absoluteCapacity=" + queueCapacities.getAbsoluteCapacity() + ", " + 
   "usedResources=" + queueUsage.getUsed() +  ", " +
   "usedCapacity=" + getUsedCapacity() + ", " + 
   "absoluteUsedCapacity=" + getAbsoluteUsedCapacity() + ", " +
   "numApps=" + getNumApplications() + ", " + 
   "numContainers=" + getNumContainers();  
}

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

/**
 * Set maximum capacity - used only for testing.
 * @param maximumCapacity new max capacity
 */
synchronized void setMaxCapacity(float maximumCapacity) {
 // Sanity check
 CSQueueUtils.checkMaxCapacity(getQueueName(),
   queueCapacities.getCapacity(), maximumCapacity);
 float absMaxCapacity =
   CSQueueUtils.computeAbsoluteMaximumCapacity(maximumCapacity, parent);
 CSQueueUtils.checkAbsoluteCapacity(getQueueName(),
   queueCapacities.getAbsoluteCapacity(),
   absMaxCapacity);
 
 queueCapacities.setMaximumCapacity(maximumCapacity);
 queueCapacities.setAbsoluteMaximumCapacity(absMaxCapacity);
}

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

/**
 * Set maximum capacity - used only for testing.
 * @param maximumCapacity new max capacity
 */
synchronized void setMaxCapacity(float maximumCapacity) {
 // Sanity check
 CSQueueUtils.checkMaxCapacity(getQueueName(),
   queueCapacities.getCapacity(), maximumCapacity);
 float absMaxCapacity =
   CSQueueUtils.computeAbsoluteMaximumCapacity(maximumCapacity, parent);
 CSQueueUtils.checkAbsoluteCapacity(getQueueName(),
   queueCapacities.getAbsoluteCapacity(),
   absMaxCapacity);
 
 queueCapacities.setMaximumCapacity(maximumCapacity);
 queueCapacities.setAbsoluteMaximumCapacity(absMaxCapacity);
}

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

protected QueueInfo getQueueInfo() {
 QueueInfo queueInfo = recordFactory.newRecordInstance(QueueInfo.class);
 queueInfo.setQueueName(queueName);
 queueInfo.setAccessibleNodeLabels(accessibleLabels);
 queueInfo.setCapacity(queueCapacities.getCapacity());
 queueInfo.setMaximumCapacity(queueCapacities.getMaximumCapacity());
 queueInfo.setQueueState(state);
 queueInfo.setDefaultNodeLabelExpression(defaultLabelExpression);
 queueInfo.setCurrentCapacity(getUsedCapacity());
 return queueInfo;
}

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

protected QueueInfo getQueueInfo() {
 QueueInfo queueInfo = recordFactory.newRecordInstance(QueueInfo.class);
 queueInfo.setQueueName(queueName);
 queueInfo.setAccessibleNodeLabels(accessibleLabels);
 queueInfo.setCapacity(queueCapacities.getCapacity());
 queueInfo.setMaximumCapacity(queueCapacities.getMaximumCapacity());
 queueInfo.setQueueState(state);
 queueInfo.setDefaultNodeLabelExpression(defaultLabelExpression);
 queueInfo.setCurrentCapacity(getUsedCapacity());
 return queueInfo;
}

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

protected void validateCapacitiesByLabel(ManagedParentQueue
  autoCreateEnabledParentQueue, AutoCreatedLeafQueue leafQueue, String
  label) throws InterruptedException {
 assertEquals(autoCreateEnabledParentQueue.getLeafQueueTemplate()
     .getQueueCapacities().getCapacity(label),
   leafQueue.getQueueCapacities()
     .getCapacity(label), EPSILON);
 assertEquals(autoCreateEnabledParentQueue.getLeafQueueTemplate()
     .getQueueCapacities().getMaximumCapacity(label),
   leafQueue.getQueueCapacities()
     .getMaximumCapacity(label), EPSILON);
}

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

protected QueueInfo getQueueInfo() {
 // Deliberately doesn't use lock here, because this method will be invoked
 // from schedulerApplicationAttempt, to avoid deadlock, sacrifice
 // consistency here.
 // TODO, improve this
 QueueInfo queueInfo = recordFactory.newRecordInstance(QueueInfo.class);
 queueInfo.setQueueName(queueName);
 queueInfo.setAccessibleNodeLabels(accessibleLabels);
 queueInfo.setCapacity(queueCapacities.getCapacity());
 queueInfo.setMaximumCapacity(queueCapacities.getMaximumCapacity());
 queueInfo.setQueueState(getState());
 queueInfo.setDefaultNodeLabelExpression(defaultLabelExpression);
 queueInfo.setCurrentCapacity(getUsedCapacity());
 queueInfo.setQueueStatistics(getQueueStatistics());
 queueInfo.setPreemptionDisabled(preemptionDisabled);
 queueInfo.setIntraQueuePreemptionDisabled(
   getIntraQueuePreemptionDisabled());
 queueInfo.setQueueConfigurations(getQueueConfigurations());
 return queueInfo;
}

内容来源于网络，如有侵权，请联系作者删除！

QueueCapacities

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com