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

QueueMetrics._incrPendingResources介绍

暂无

代码示例

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

/**
 * Increment pending resource metrics
 * @param partition Node Partition
 * @param user
 * @param containers
 * @param res the TOTAL delta of resources note this is different from
 *            the other APIs which use per container resource
 */
public void incrPendingResources(String partition, String user,
  int containers, Resource res) {
 if(partition == null || partition.equals(RMNodeLabelsManager.NO_LABEL)) {
  _incrPendingResources(containers, res);
  QueueMetrics userMetrics = getUserMetrics(user);
  if (userMetrics != null) {
   userMetrics.incrPendingResources(partition, user, containers, res);
  }
  if (parent != null) {
   parent.incrPendingResources(partition, user, containers, res);
  }
 }
}

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

/**
 * Increment pending resource metrics
 * @param user
 * @param containers
 * @param res the TOTAL delta of resources note this is different from
 *            the other APIs which use per container resource
 */
public void incrPendingResources(String user, int containers, Resource res) {
 _incrPendingResources(containers, res);
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.incrPendingResources(user, containers, res);
 }
 if (parent != null) {
  parent.incrPendingResources(user, containers, res);
 }
}

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

/**
 * Increment pending resource metrics
 * @param user
 * @param containers
 * @param res the TOTAL delta of resources note this is different from
 *            the other APIs which use per container resource
 */
public void incrPendingResources(String user, int containers, Resource res) {
 _incrPendingResources(containers, res);
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.incrPendingResources(user, containers, res);
 }
 if (parent != null) {
  parent.incrPendingResources(user, containers, res);
 }
}