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

Resources.addTo介绍

暂无

代码示例

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

public void addAMResourceUsage(Resource amResource) {
 if (amResource != null) {
  Resources.addTo(amResourceUsage, amResource);
 }
}

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

public void addAMResourceUsage(Resource amResource) {
 if (amResource != null) {
  Resources.addTo(amResourceUsage, amResource);
 }
}

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

/**
 * When adding a child we also aggregate its pending resource needs.
 *
 * @param q
 *          the child queue to add to this queue
 */
public void addChild(TempQueuePerPartition q) {
 assert leafQueue == null;
 children.add(q);
 Resources.addTo(pending, q.pending);
 Resources.addTo(pendingDeductReserved, q.pendingDeductReserved);
}

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

private void incToPreempt(String queue, String partition,
  Resource allocated) {
 Resource total = toPreemptedFromOtherQueues.get(queue, partition);
 if (null == total) {
  total = Resources.createResource(0);
  toPreemptedFromOtherQueues.put(queue, partition, total);
 }
 Resources.addTo(total, allocated);
}

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

public void addPreemption(RMContainer container, long time) {
 assert preemptionMap.get(container) == null;
 preemptionMap.put(container, time);
 Resources.addTo(preemptedResources, container.getAllocatedResource());
}

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

public void addPreemption(RMContainer container, long time) {
 assert preemptionMap.get(container) == null;
 preemptionMap.put(container, time);
 Resources.addTo(preemptedResources, container.getAllocatedResource());
}

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

public void addBlockedHeadroom(Resource resource) {
 if (blockedHeadroom == null) {
  blockedHeadroom = Resource.newInstance(0, 0);
 }
 Resources.addTo(blockedHeadroom, resource);
}

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

public Resource getCachedDemand(String label) {
  try {
   readLock.lock();
   Resource demand = Resources.createResource(0);
   Resources.addTo(demand, getCachedUsed(label));
   Resources.addTo(demand, getCachedPending(label));
   return demand;
  } finally {
   readLock.unlock();
  }
 }
}

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

public synchronized void markContainerToKillable(ContainerId containerId) {
 RMContainer c = getContainer(containerId);
 if (c != null && !killableContainers.containsKey(containerId)) {
  killableContainers.put(containerId, c);
  Resources.addTo(totalKillableResources, c.getAllocatedResource());
 }
}

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

private synchronized void deductAvailableResource(Resource resource) {
 if (resource == null) {
  LOG.error("Invalid deduction of null resource for "
    + rmNode.getNodeAddress());
  return;
 }
 Resources.subtractFrom(availableResource, resource);
 Resources.addTo(usedResource, resource);
}

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

private synchronized void addAvailableResource(Resource resource) {
 if (resource == null) {
  LOG.error("Invalid resource addition of null resource for "
    + rmNode.getNodeAddress());
  return;
 }
 Resources.addTo(availableResource, resource);
 Resources.subtractFrom(usedResource, resource);
}

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

void addAMResourceUsage(Resource amResource) {
 if (amResource != null) {
  Resources.addTo(amResourceUsage, amResource);
  getMetrics().setAMResourceUsage(amResourceUsage);
 }
}

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

private synchronized void addNode(RMNode nodeManager) {
 FiCaSchedulerNode schedulerNode = new FiCaSchedulerNode(nodeManager,
   usePortForNodeName);
 this.nodes.put(nodeManager.getNodeID(), schedulerNode);
 Resources.addTo(clusterResource, schedulerNode.getTotalResource());
 updateMaximumAllocation(schedulerNode, true);
}

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

public void resetPreemptedResources() {
 preemptedResources = Resources.createResource(0);
 for (RMContainer container : getPreemptionContainers()) {
  Resources.addTo(preemptedResources, container.getAllocatedResource());
 }
}

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

private synchronized void addNode(RMNode nodeManager) {
 FiCaSchedulerNode schedulerNode = new FiCaSchedulerNode(nodeManager,
   usePortForNodeName);
 this.nodes.put(nodeManager.getNodeID(), schedulerNode);
 Resources.addTo(clusterResource, schedulerNode.getTotalResource());
 updateMaximumAllocation(schedulerNode, true);
}

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

static Resource leafAbsCapacities(Resource[] abs, int[] subqueues) {
 Resource ret = Resource.newInstance(0, 0);
 for (int i = 0; i < abs.length; ++i) {
  if (0 == subqueues[i]) {
   Resources.addTo(ret, abs[i]);
  }
 }
 return ret;
}

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

private synchronized void addNode(RMNode node) {
 FSSchedulerNode schedulerNode = new FSSchedulerNode(node, usePortForNodeName);
 nodes.put(node.getNodeID(), schedulerNode);
 Resources.addTo(clusterResource, schedulerNode.getTotalResource());
 updateRootQueueMetrics();
 updateMaximumAllocation(schedulerNode, true);
 queueMgr.getRootQueue().setSteadyFairShare(clusterResource);
 queueMgr.getRootQueue().recomputeSteadyShares();
 LOG.info("Added node " + node.getNodeAddress() +
   " cluster capacity: " + clusterResource);
}

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

private synchronized void addNode(RMNode node) {
 FSSchedulerNode schedulerNode = new FSSchedulerNode(node, usePortForNodeName);
 nodes.put(node.getNodeID(), schedulerNode);
 Resources.addTo(clusterResource, schedulerNode.getTotalResource());
 updateRootQueueMetrics();
 updateMaximumAllocation(schedulerNode, true);
 queueMgr.getRootQueue().setSteadyFairShare(clusterResource);
 queueMgr.getRootQueue().recomputeSteadyShares();
 LOG.info("Added node " + node.getNodeAddress() +
   " cluster capacity: " + clusterResource);
}

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

public synchronized Resource getTotalPendingRequests() {
 Resource ret = Resource.newInstance(0, 0);
 for (ResourceRequest rr : appSchedulingInfo.getAllResourceRequests()) {
  // to avoid double counting we count only "ANY" resource requests
  if (ResourceRequest.isAnyLocation(rr.getResourceName())){
   Resources.addTo(ret,
     Resources.multiply(rr.getCapability(), rr.getNumContainers()));
  }
 }
 return ret;
}

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

public synchronized Resource getTotalPendingRequests() {
 Resource ret = Resource.newInstance(0, 0);
 for (ResourceRequest rr : appSchedulingInfo.getAllResourceRequests()) {
  // to avoid double counting we count only "ANY" resource requests
  if (ResourceRequest.isAnyLocation(rr.getResourceName())){
   Resources.addTo(ret,
     Resources.multiply(rr.getCapability(), rr.getNumContainers()));
  }
 }
 return ret;
}