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

Resources.subtract介绍

[英]Subtract rhs from lhs and reset any negative values to zero. This call will modify lhs.
[中]从lhs中减去rhs，并将所有负值重置为零。此调用将修改lhs。

代码示例

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

/**
 * Set total resources on the node.
 * @param resource total resources on the node.
 */
public synchronized void setTotalResource(Resource resource){
 this.totalResourceCapability = resource;
 this.availableResource = Resources.subtract(totalResourceCapability,
  this.usedResource);
}

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

/**
 * Set total resources on the node.
 * @param resource total resources on the node.
 */
public synchronized void setTotalResource(Resource resource){
 this.totalResourceCapability = resource;
 this.availableResource = Resources.subtract(totalResourceCapability,
  this.usedResource);
}

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

/**
 * Set total resources on the node.
 * @param resource Total resources on the node.
 */
public synchronized void updateTotalResource(Resource resource){
 this.totalResource = resource;
 this.unallocatedResource = Resources.subtract(totalResource,
   this.allocatedResource);
}

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

public Resource getNetLimit() {
  if (blockedHeadroom != null) {
   return Resources.subtract(limit, blockedHeadroom);
  }
  return limit;
 }
}

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

public static Resource negate(Resource resource) {
 return subtract(NONE, resource);
}

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

private void updateNMResource(Resource resource) {
 metrics.addResource(Resources.subtract(resource, totalResource));
 this.totalResource = resource;
}

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

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

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

/**
 * Get the current app's unsatisfied demand.
 */
Resource getPendingDemand() {
 return Resources.subtract(demand, getResourceUsage());
}

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

/**
 * Delta capacity = target - before, so if it is a decrease request, delta
 * capacity will be negative
 */
public synchronized Resource getDeltaCapacity() {
 // Only calculate deltaCapacity once
 if (deltaCapacity == null) {
  deltaCapacity = Resources.subtract(
    targetCapacity, rmContainer.getAllocatedResource());
 }
 return deltaCapacity;
}

代码示例来源：origin: io.hops/hadoop-yarn-server-nodemanager

private void updateNMResource(Resource resource) {
 metrics.addResource(Resources.subtract(resource, totalResource));
 this.totalResource = resource;
}

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

protected void _dec(String label, ResourceType type, Resource res) {
 try {
  writeLock.lock();
  UsageByLabel usage = getAndAddIfMissing(label);
  usage.resArr.set(type.idx,
    Resources.subtract(usage.resArr.get(type.idx), res));
 } finally {
  writeLock.unlock();
 }
}

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

/**
 * Subqueue metrics might be a little out of date because fair shares are
 * recalculated at the update interval, but the root queue metrics needs to
 * be updated synchronously with allocations and completions so that cluster
 * metrics will be consistent.
 */
private void updateRootQueueMetrics() {
 rootMetrics.setAvailableResourcesToQueue(
   Resources.subtract(
     clusterResource, rootMetrics.getAllocatedResources()));
}

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

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

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

/**
 * Subqueue metrics might be a little out of date because fair shares are
 * recalculated at the update interval, but the root queue metrics needs to
 * be updated synchronously with allocations and completions so that cluster
 * metrics will be consistent.
 */
private void updateRootQueueMetrics() {
 rootMetrics.setAvailableResourcesToQueue(
   Resources.subtract(
     clusterResource, rootMetrics.getAllocatedResources()));
}

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

public void assignPreemption(float scalingFactor,
  ResourceCalculator rc, Resource clusterResource) {
 if (Resources.greaterThan(rc, clusterResource, current, idealAssigned)) {
   toBePreempted = Resources.multiply(
     Resources.subtract(current, idealAssigned), scalingFactor);
 } else {
  toBePreempted = Resource.newInstance(0, 0);
 }
}

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

public void assignPreemption(float scalingFactor,
  ResourceCalculator rc, Resource clusterResource) {
 if (Resources.greaterThan(rc, clusterResource, current, idealAssigned)) {
   toBePreempted = Resources.multiply(
     Resources.subtract(current, idealAssigned), scalingFactor);
 } else {
  toBePreempted = Resource.newInstance(0, 0);
 }
}

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

/**
 * Subqueue metrics might be a little out of date because fair shares are
 * recalculated at the update interval, but the root queue metrics needs to
 * be updated synchronously with allocations and completions so that cluster
 * metrics will be consistent.
 */
private void updateRootQueueMetrics() {
 rootMetrics.setAvailableResourcesToQueue(
   Resources.subtract(
     getClusterResource(), rootMetrics.getAllocatedResources()));
}

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

@Override
public Resource getResourceUsage() {
 // Here the getPreemptedResources() always return zero, except in
 // a preemption round
 // In the common case where preempted resource is zero, return the
 // current consumption Resource object directly without calling
 // Resources.subtract which creates a new Resource object for each call.
 return getPreemptedResources().equals(Resources.none()) ?
   getCurrentConsumption() :
   Resources.subtract(getCurrentConsumption(), getPreemptedResources());
}

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

@Override
public Resource getResourceUsage() {
 // Here the getPreemptedResources() always return zero, except in
 // a preemption round
 // In the common case where preempted resource is zero, return the
 // current consumption Resource object directly without calling
 // Resources.subtract which creates a new Resource object for each call.
 return getPreemptedResources().equals(Resources.none()) ?
   getCurrentConsumption() :
   Resources.subtract(getCurrentConsumption(), getPreemptedResources());
}

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

@Test
public void testSubtract() {
 assertEquals(createResource(1, 0),
   subtract(createResource(2, 1), createResource(1, 1)));
 assertEquals(createResource(0, 1),
   subtract(createResource(1, 2), createResource(1, 1)));
 assertEquals(createResource(2, 2, 0),
   subtract(createResource(3, 3, 0), createResource(1, 1, 0)));
 assertEquals(createResource(1, 1, 2),
   subtract(createResource(2, 2, 3), createResource(1, 1, 1)));
}