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

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

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

QueueCapacities.getAbsoluteUsedCapacity介绍

暂无

代码示例

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

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

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

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

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

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

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

diagnosticMessage.append("Queue's Absolute used capacity = ");
diagnosticMessage.append(
  queueCapacities.getAbsoluteUsedCapacity(appAMNodePartitionName) * 100);
diagnosticMessage.append(" % ; ");
diagnosticMessage.append("Queue's Absolute max capacity = ");

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

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

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

private void setPreemptionAllowed(ResourceLimits limits, String nodePartition) {
 // Set preemption-allowed:
 // For leaf queue, only under-utilized queue is allowed to preempt resources from other queues
 if (!queueResourceQuotas.getEffectiveMinResource(nodePartition)
   .equals(Resources.none())) {
  limits.setIsAllowPreemption(Resources.lessThan(resourceCalculator,
    csContext.getClusterResource(), queueUsage.getUsed(nodePartition),
    queueResourceQuotas.getEffectiveMinResource(nodePartition)));
  return;
 }
 float usedCapacity = queueCapacities.getAbsoluteUsedCapacity(nodePartition);
 float guaranteedCapacity = queueCapacities.getAbsoluteCapacity(nodePartition);
 limits.setIsAllowPreemption(usedCapacity < guaranteedCapacity);
}

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

if (getQueueCapacities()
  .getAbsoluteMaximumCapacity(nodePartition) < getQueueCapacities()
    .getAbsoluteUsedCapacity(nodePartition)) {
 killContainersToEnforceMaxQueueCapacity(nodePartition,
   clusterResource);

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

public void checkAbsCapacities(CSQueue queue, String partition,
  float guaranteed, float max, float used) {
 QueueCapacities qc = queue.getQueueCapacities();
 Assert.assertEquals(guaranteed, qc.getAbsoluteCapacity(partition), 1e-3);
 Assert.assertEquals(max, qc.getAbsoluteMaximumCapacity(partition), 1e-3);
 Assert.assertEquals(used, qc.getAbsoluteUsedCapacity(partition), 1e-3);
}

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

.cap(capacities.getAbsoluteCapacity(partitionName), 0f, 1f) * 100;
absUsedCapacity = CapacitySchedulerQueueInfo
  .cap(capacities.getAbsoluteUsedCapacity(partitionName), 0f, 1f) * 100;
absMaxCapacity = CapacitySchedulerQueueInfo.cap(
  capacities.getAbsoluteMaximumCapacity(partitionName), 0f, 1f) * 100;

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

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

相关文章