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

QueueMetrics.setAvailableResourcesToQueue介绍

[英]Set available resources. To be called by scheduler periodically as resources become available.
[中]设置可用资源。在资源可用时由调度程序定期调用。

代码示例

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

/**
 * Set available resources. To be called by scheduler periodically as
 * resources become available.
 * @param limit resource limit
 */
public void setAvailableResourcesToQueue(Resource limit) {
 this.setAvailableResourcesToQueue(RMNodeLabelsManager.NO_LABEL, limit);
}

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

/**
 * Set available resources. To be called by scheduler periodically as
 * resources become available.
 * @param user
 * @param limit resource limit
 */
public void setAvailableResourcesToUser(String user, Resource limit) {
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.setAvailableResourcesToQueue(limit);
 }
}

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

/**
 * Set available resources. To be called by scheduler periodically as
 * resources become available.
 * @param user
 * @param limit resource limit
 */
public void setAvailableResourcesToUser(String user, Resource limit) {
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.setAvailableResourcesToQueue(limit);
 }
}

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

private void updateAvailableResourcesMetrics() {
 metrics.setAvailableResourcesToQueue(Resources.subtract(clusterResource,
  usedResource));
}

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

private void updateAvailableResourcesMetrics() {
 metrics.setAvailableResourcesToQueue(Resources.subtract(clusterResource,
  usedResource));
}

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

/**
 * Set available resources. To be called by scheduler periodically as
 * resources become available.
 * @param partition Node Partition
 * @param user
 * @param limit resource limit
 */
public void setAvailableResourcesToUser(String partition,
  String user, Resource limit) {
 if(partition == null || partition.equals(RMNodeLabelsManager.NO_LABEL)) {
  QueueMetrics userMetrics = getUserMetrics(user);
  if (userMetrics != null) {
   userMetrics.setAvailableResourcesToQueue(partition, limit);
  }
 }
}

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

private void updateAvailableResourcesMetrics() {
 metrics.setAvailableResourcesToQueue(
   Resources.subtract(getClusterResource(), usedResource));
}

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

@Test(timeout = 5000)
public void testManyRuns() {
 QueueMetrics qm =
   QueueMetrics.forQueue(metricsSystem, "root", null, false, conf);
 qm.setAvailableResourcesToQueue(RMNodeLabelsManager.NO_LABEL,
   Resource.newInstance(1, 1));
 int numIterations = 1000;
 long start = System.currentTimeMillis();
 for (int i = 0; i < numIterations; i++) {
  ic.editSchedule();
 }
 long end = System.currentTimeMillis();
 System.out.println("Runtime per iteration (avg of " + numIterations
   + " iterations): " + (end - start) + " tot time");
}

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

@Test
public void testViolation() {
 // create a "wrong" condition in which the invariants are not respected
 QueueMetrics qm =
   QueueMetrics.forQueue(metricsSystem, "root", null, false, conf);
 qm.setAvailableResourcesToQueue(RMNodeLabelsManager.NO_LABEL,
   Resource.newInstance(-1, -1));
 // test with throwing exception turned on
 try {
  ic.editSchedule();
  fail();
 } catch (InvariantViolationException i) {
  // expected
 }
 // test log-only mode
 conf.setBoolean(MetricsInvariantChecker.THROW_ON_VIOLATION, false);
 ic.init(conf, null, null);
 ic.editSchedule();
}

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

childQueue.getMetrics().setAvailableResourcesToQueue(
  Resources.max(
    calculator,

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

childQueue.getMetrics().setAvailableResourcesToQueue(
  Resources.max(
    calculator,

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

checkApps(parentUserSource, 1, 1, 0, 0, 0, 0, true);
parentMetrics.setAvailableResourcesToQueue(RMNodeLabelsManager.NO_LABEL,
  Resources.createResource(100*GB, 100));
metrics.setAvailableResourcesToQueue(RMNodeLabelsManager.NO_LABEL,
  Resources.createResource(100*GB, 100));
parentMetrics.setAvailableResourcesToUser(RMNodeLabelsManager.NO_LABEL,

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

checkApps(queueSource, 1, 1, 0, 0, 0, 0, true);
metrics.setAvailableResourcesToQueue(Resources.createResource(100*GB, 100));
metrics.incrPendingResources(user, 5, Resources.createResource(3*GB, 3));

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

checkApps(queueSource, 1, 1, 0, 0, 0, 0, true);
metrics.setAvailableResourcesToQueue(RMNodeLabelsManager.NO_LABEL,
  Resources.createResource(100*GB, 100));
metrics.incrPendingResources(RMNodeLabelsManager.NO_LABEL,

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

checkApps(parentUserSource, 1, 1, 0, 0, 0, 0, true);
parentMetrics.setAvailableResourcesToQueue(Resources.createResource(100*GB, 100));
metrics.setAvailableResourcesToQueue(Resources.createResource(100*GB, 100));
parentMetrics.setAvailableResourcesToUser(user, Resources.createResource(10*GB, 10));
metrics.setAvailableResourcesToUser(user, Resources.createResource(10*GB, 10));

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

checkApps(userSource, 1, 1, 0, 0, 0, 0, true);
metrics.setAvailableResourcesToQueue(Resources.createResource(100*GB, 100));
metrics.setAvailableResourcesToUser(user, Resources.createResource(10*GB, 10));
metrics.incrPendingResources(user, 5, Resources.createResource(3*GB, 3));

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

checkApps(userSource, 1, 1, 0, 0, 0, 0, true);
metrics.setAvailableResourcesToQueue(RMNodeLabelsManager.NO_LABEL,
  Resources.createResource(100*GB, 100));
metrics.setAvailableResourcesToUser(RMNodeLabelsManager.NO_LABEL,