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

Resources.clone介绍

暂无

代码示例

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

@Override
public void setTotalCapacity(Resource cap) {
 writeLock.lock();
 try {
  totalCapacity = Resources.clone(cap);
 } finally {
  writeLock.unlock();
 }
}

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

public void setConfiguredMaxAllocation(Resource resource) {
 writeLock.lock();
 try {
  configuredMaxAllocation = Resources.clone(resource);
 } finally {
  writeLock.unlock();
 }
}

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

@Override
public void setTotalCapacity(Resource cap) {
 writeLock.lock();
 try {
  totalCapacity = Resources.clone(cap);
 } finally {
  writeLock.unlock();
 }
}

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

@Override
public Resource getTotalCapacity() {
 readLock.lock();
 try {
  return Resources.clone(totalCapacity);
 } finally {
  readLock.unlock();
 }
}

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

@Override
public Resource getTotalCapacity() {
 readLock.lock();
 try {
  return Resources.clone(totalCapacity);
 } finally {
  readLock.unlock();
 }
}

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

@Override
public Resource getTotalCapacity() {
 readLock.lock();
 try {
  return Resources.clone(totalCapacity);
 } finally {
  readLock.unlock();
 }
}

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

/**
 * Subtract {@code rhs} from {@code lhs} and reset any negative values to
 * zero. This call will operate on a copy of {@code lhs}, leaving {@code lhs}
 * unmodified.
 *
 * @param lhs {@link Resource} to subtract from
 * @param rhs {@link Resource} to subtract
 * @return the value of lhs after subtraction
 */
public static Resource subtractNonNegative(Resource lhs, Resource rhs) {
 return subtractFromNonNegative(clone(lhs), rhs);
}

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

/**
 * This method is visible to allow sub-classes to ovverride the behavior,
 * specifically for federation purposes we need to initialize per-sub-cluster
 * roots as well as the global one.
 */
protected void initializeRootIdealWithGuarangeed() {
 idealAssigned = Resources.clone(getGuaranteed());
}

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

@Override
public Resource getResource() {
 return Resources.clone(
   this.containerTokenIdentifier.getResource());
}

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

@Override
public Resource getResourcesAtTime(long tick) {
 if (tick < startTime || tick >= endTime) {
  return Resource.newInstance(0, 0);
 }
 return Resources.clone(resourcesOverTime.getCapacityAtTime(tick));
}

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

@Override
public void setResource(Resource targetResource) {
 Resource currentResource = getResource();
 this.resource = Resources.clone(targetResource);
 this.metrics.changeContainer(currentResource, targetResource);
}

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

@Override
public Resource getEffectiveMaxCapacity(String label) {
 return Resources
   .clone(getQueueResourceQuotas().getEffectiveMaxResource(label));
}

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

public Resource getGuaranteed() {
 if(!effMinRes.equals(Resources.none())) {
  return Resources.clone(effMinRes);
 }
 return Resources.multiply(totalPartitionResource, absCapacity);
}

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

public Resource getMax() {
 if(!effMaxRes.equals(Resources.none())) {
  return Resources.clone(effMaxRes);
 }
 return Resources.multiply(totalPartitionResource, absMaxCapacity);
}

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

public void setApplicationHeadroomForMetrics(Resource headroom) {
 RMAppAttempt attempt =
   rmContext.getRMApps().get(attemptId.getApplicationId())
     .getCurrentAppAttempt();
 if (attempt != null) {
  attempt.getRMAppAttemptMetrics().setApplicationAttemptHeadRoom(
    Resources.clone(headroom));
 }
}

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

public static Resource multiplyAndRoundDown(Resource lhs, double by) {
 Resource out = clone(lhs);
 out.setMemory((int)(lhs.getMemory() * by));
 out.setVirtualCores((int)(lhs.getVirtualCores() * by));
 return out;
}

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

public static Resource multiplyAndRoundDown(Resource lhs, double by) {
 Resource out = clone(lhs);
 out.setMemory((int)(lhs.getMemory() * by));
 out.setVirtualCores((int)(lhs.getVirtualCores() * by));
 return out;
}

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

@Test
public void testClone() {
 assertEquals(createResource(1, 1), Resources.clone(createResource(1, 1)));
 assertEquals(createResource(1, 1, 0),
   Resources.clone(createResource(1, 1)));
 assertEquals(createResource(1, 1),
   Resources.clone(createResource(1, 1, 0)));
 assertEquals(createResource(1, 1, 2),
   Resources.clone(createResource(1, 1, 2)));
}

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

@Override
public void editSchedule() {
 CSQueue root = scheduler.getRootQueue();
 Resource clusterResources = Resources.clone(scheduler.getClusterResource());
 clusterResources = getNonLabeledResources(clusterResources);
 setNodeLabels(scheduler.getRMContext().getNodeLabelManager()
   .getNodeLabels());
 containerBasedPreemptOrKill(root, clusterResources);
}

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

@Test(timeout = 10000)
public void testCompareToWithUnboundedResource() {
 unsetExtraResourceType();
 Resource unboundedClone = Resources.clone(ExtendedResources.unbounded());
 assertTrue(unboundedClone
   .compareTo(createResource(Long.MAX_VALUE, Integer.MAX_VALUE)) == 0);
 assertTrue(unboundedClone.compareTo(createResource(Long.MAX_VALUE, 0)) > 0);
 assertTrue(
   unboundedClone.compareTo(createResource(0, Integer.MAX_VALUE)) > 0);
}