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

QueueCapacities.<init>介绍

暂无

代码示例

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

public AbstractCSQueue(CapacitySchedulerContext cs,
  CapacitySchedulerConfiguration configuration, String queueName,
  CSQueue parent, CSQueue old) {
 this.labelManager = cs.getRMContext().getNodeLabelManager();
 this.parent = parent;
 this.queueName = queueName;
 this.queuePath = ((parent == null) ? "" : (parent.getQueuePath() + "."))
   + this.queueName;
 this.resourceCalculator = cs.getResourceCalculator();
 this.activitiesManager = cs.getActivitiesManager();
 // must be called after parent and queueName is set
 this.metrics = old != null ?
   (CSQueueMetrics) old.getMetrics() :
   CSQueueMetrics.forQueue(getQueuePath(), parent,
     cs.getConfiguration().getEnableUserMetrics(), cs.getConf());
 this.csContext = cs;
 this.minimumAllocation = csContext.getMinimumResourceCapability();
 // initialize ResourceUsage
 queueUsage = new ResourceUsage();
 queueEntity = new PrivilegedEntity(EntityType.QUEUE, getQueuePath());
 // initialize QueueCapacities
 queueCapacities = new QueueCapacities(parent == null);
 // initialize queueResourceQuotas
 queueResourceQuotas = new QueueResourceQuotas();
 ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
 readLock = lock.readLock();
 writeLock = lock.writeLock();
}

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

QueueCapacities qc = new QueueCapacities(0 == myLevel);
ResourceUsage ru = new ResourceUsage();
QueueResourceQuotas qr  = new QueueResourceQuotas();

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

protected AutoCreatedLeafQueueConfig.Builder initializeLeafQueueConfigs() {
 AutoCreatedLeafQueueConfig.Builder builder =
   new AutoCreatedLeafQueueConfig.Builder();
 String leafQueueTemplateConfPrefix = getLeafQueueConfigPrefix(
   csContext.getConfiguration());
 //Load template configuration
 builder.configuration(
   super.initializeLeafQueueConfigs(leafQueueTemplateConfPrefix));
 //Load template capacities
 QueueCapacities queueCapacities = new QueueCapacities(false);
 CSQueueUtils.loadUpdateAndCheckCapacities(csContext.getConfiguration()
     .getAutoCreatedQueueTemplateConfPrefix(getQueuePath()),
   csContext.getConfiguration(), queueCapacities, getQueueCapacities());
 builder.capacities(queueCapacities);
 return builder;
}

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

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

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

public AbstractCSQueue(CapacitySchedulerContext cs, 
  String queueName, CSQueue parent, CSQueue old) throws IOException {
 this.labelManager = cs.getRMContext().getNodeLabelManager();
 this.parent = parent;
 this.queueName = queueName;
 this.resourceCalculator = cs.getResourceCalculator();
 
 // must be called after parent and queueName is set
 this.metrics = old != null ? old.getMetrics() :
   QueueMetrics.forQueue(getQueuePath(), parent,
     cs.getConfiguration().getEnableUserMetrics(),
     cs.getConf());
 this.csContext = cs;
 this.minimumAllocation = csContext.getMinimumResourceCapability();
 
 // initialize ResourceUsage
 queueUsage = new ResourceUsage();
 queueEntity = new PrivilegedEntity(EntityType.QUEUE, getQueuePath());
 
 // initialize QueueCapacities
 queueCapacities = new QueueCapacities(parent == null);    
}

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

public AbstractCSQueue(CapacitySchedulerContext cs, 
  String queueName, CSQueue parent, CSQueue old) throws IOException {
 this.labelManager = cs.getRMContext().getNodeLabelManager();
 this.parent = parent;
 this.queueName = queueName;
 this.resourceCalculator = cs.getResourceCalculator();
 
 // must be called after parent and queueName is set
 this.metrics = old != null ? old.getMetrics() :
   QueueMetrics.forQueue(getQueuePath(), parent,
     cs.getConfiguration().getEnableUserMetrics(),
     cs.getConf());
 this.csContext = cs;
 this.minimumAllocation = csContext.getMinimumResourceCapability();
 
 // initialize ResourceUsage
 queueUsage = new ResourceUsage();
 queueEntity = new PrivilegedEntity(EntityType.QUEUE, getQueuePath());
 
 // initialize QueueCapacities
 queueCapacities = new QueueCapacities(parent == null);    
}

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

private void internalTestModifyAndRead(String label) throws Exception {
 QueueCapacities qc = new QueueCapacities(false);
 // First get returns 0 always
 Assert.assertEquals(0f, get(qc, suffix, label), 1e-8);
 // Set to 1, and check
 set(qc, suffix, label, 1f);
 Assert.assertEquals(1f, get(qc, suffix, label), 1e-8);
 // Set to 2, and check
 set(qc, suffix, label, 2f);
 Assert.assertEquals(2f, get(qc, suffix, label), 1e-8);
}

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

private void internalTestModifyAndRead(String label) throws Exception {
 QueueCapacities qc = new QueueCapacities(false);
 // First get returns 0 always
 Assert.assertEquals(0f, get(qc, suffix, label), 1e-8);
 // Set to 1, and check
 set(qc, suffix, label, 1f);
 Assert.assertEquals(1f, get(qc, suffix, label), 1e-8);
 // Set to 2, and check
 set(qc, suffix, label, 2f);
 Assert.assertEquals(2f, get(qc, suffix, label), 1e-8);
}