org.apache.hadoop.yarn.util.resource.Resources.greaterThan()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(8.2k)|赞(0)|评价(0)|浏览(112)

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

Resources.greaterThan介绍

暂无

代码示例

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

/**
 * Check if plan resources are less than expected reservation resources.
 */
private boolean arePlanResourcesLessThanReservations(
  ResourceCalculator rescCalculator, Resource clusterResources,
  Resource planResources, Resource reservedResources) {
 return Resources.greaterThan(rescCalculator, clusterResources,
   reservedResources, planResources);
}

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

private void assertResourcesOperations(Resource clusterResource,
  Resource lhs, Resource rhs, boolean lessThan, boolean lessThanOrEqual,
  boolean greaterThan, boolean greaterThanOrEqual, Resource max,
  Resource min) {
 assertEquals("Less Than operation is wrongly calculated.", lessThan,
   Resources.lessThan(resourceCalculator, clusterResource, lhs, rhs));
 assertEquals(
   "Less Than Or Equal To operation is wrongly calculated.",
   lessThanOrEqual, Resources.lessThanOrEqual(resourceCalculator,
     clusterResource, lhs, rhs));
 assertEquals("Greater Than operation is wrongly calculated.",
   greaterThan,
   Resources.greaterThan(resourceCalculator, clusterResource, lhs, rhs));
 assertEquals(
   "Greater Than Or Equal To operation is wrongly calculated.",
   greaterThanOrEqual, Resources.greaterThanOrEqual(resourceCalculator,
     clusterResource, lhs, rhs));
 assertEquals("Max(value) Operation wrongly calculated.", max,
   Resources.max(resourceCalculator, clusterResource, lhs, rhs));
 assertEquals("Min(value) operation is wrongly calculated.", min,
   Resources.min(resourceCalculator, clusterResource, lhs, rhs));
}

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

@Override
public boolean checkIfUsageOverFairShare(Resource usage, Resource fairShare) {
 return Resources.greaterThan(RESOURCE_CALCULATOR, null, usage, fairShare);
}

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

@Override
public boolean checkIfUsageOverFairShare(Resource usage, Resource fairShare) {
 return Resources.greaterThan(RESOURCE_CALCULATOR, null, usage, fairShare);
}

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

@Override
protected boolean arePlanResourcesLessThanReservations(
  Resource clusterResources, Resource planResources,
  Resource reservedResources) {
 return Resources.greaterThan(cs.getResourceCalculator(),
   clusterResources, reservedResources, planResources);
}

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

public boolean isUserLimitReached(ResourceCalculator rc,
  Resource clusterResource) {
 if (Resources.greaterThan(rc, clusterResource, getUsedDeductAM(),
   userLimit)) {
  return true;
 }
 return false;
}

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

@Override
protected boolean arePlanResourcesLessThanReservations(Resource
  clusterResources, Resource planResources, Resource reservedResources) {
 return Resources.greaterThan(fs.getResourceCalculator(),
   clusterResources, reservedResources, planResources);
}

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

@Override
protected boolean arePlanResourcesLessThanReservations(Resource
  clusterResources, Resource planResources, Resource reservedResources) {
 return Resources.greaterThan(fs.getResourceCalculator(),
   clusterResources, reservedResources, planResources);
}

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

@Override
protected boolean arePlanResourcesLessThanReservations(
  Resource clusterResources, Resource planResources,
  Resource reservedResources) {
 return Resources.greaterThan(cs.getResourceCalculator(),
   clusterResources, reservedResources, planResources);
}

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

private double getIdealPctOfGuaranteed(TempQueue q) {
  double pctOver = Integer.MAX_VALUE;
  if (q != null && Resources.greaterThan(
    rc, clusterRes, q.guaranteed, Resources.none())) {
   pctOver =
     Resources.divide(rc, clusterRes, q.idealAssigned, q.guaranteed);
  }
  return (pctOver);
 }
}

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

private static boolean hasPendingResourceRequest(ResourceCalculator rc,
  ResourceUsage usage, String partitionToLookAt, Resource cluster) {
 if (Resources.greaterThan(rc, cluster,
   usage.getPending(partitionToLookAt), Resources.none())) {
  return true;
 }
 return false;
}

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

private double getIdealPctOfGuaranteed(TempQueue q) {
  double pctOver = Integer.MAX_VALUE;
  if (q != null && Resources.greaterThan(
    rc, clusterRes, q.guaranteed, Resources.none())) {
   pctOver =
     Resources.divide(rc, clusterRes, q.idealAssigned, q.guaranteed);
  }
  return (pctOver);
 }
}

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

public void deductActuallyToBePreempted(ResourceCalculator resourceCalculator,
  Resource cluster, Resource toBeDeduct) {
 if (Resources.greaterThan(resourceCalculator, cluster,
   getActuallyToBePreempted(), toBeDeduct)) {
  Resources.subtractFrom(getActuallyToBePreempted(), toBeDeduct);
 }
}

代码示例来源：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

private double getIdealPctOfGuaranteed(TempQueuePerPartition q) {
  double pctOver = Integer.MAX_VALUE;
  if (q != null && Resources.greaterThan(rc, clusterRes, q.getGuaranteed(),
    Resources.none())) {
   pctOver = Resources.divide(rc, clusterRes, q.idealAssigned,
     q.getGuaranteed());
  }
  return (pctOver);
 }
}

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

/**
  * Retrieve absolute used resources by this queue for the specified node label.
  * @param nodeLabel label for which to get absolute used resources
  * @return absolute used resources by this queue for specified label
  */
 public final synchronized float getAbsoluteUsedCapacity(final String nodeLabel) {
  Resource totalPartitionResource =
    labelManager.getResourceByLabel(nodeLabel, this.clusterResource);
  if (!Resources.greaterThan(resourceCalculator, totalPartitionResource,
    totalPartitionResource, Resources.none())) {
   return 0.0f;
  }
  return Resources.divide(resourceCalculator, totalPartitionResource,
    queueUsage.getUsed(nodeLabel), totalPartitionResource);
 }
}

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

/**
  * Retrieve absolute used resources by this queue for the specified node label.
  * @param nodeLabel label for which to get absolute used resources
  * @return absolute used resources by this queue for specified label
  */
 public final synchronized float getAbsoluteUsedCapacity(final String nodeLabel) {
  Resource labeledResources =
        labelManager.getResourceByLabel(nodeLabel, this.clusterResource);
  if (!Resources.greaterThan(resourceCalculator, this.clusterResource,
    labeledResources, Resources.none())) {
   return 0.0f;
  }
  return Resources.divide(resourceCalculator, this.clusterResource,
    queueUsage.getUsed(nodeLabel), labeledResources);
 }
}

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

public void deductActuallyToBePreempted(ResourceCalculator rc,
  Resource cluster, Resource toBeDeduct) {
 if (Resources.greaterThan(rc, cluster, getActuallyToBePreempted(),
   toBeDeduct)) {
  Resources.subtractFrom(getActuallyToBePreempted(), toBeDeduct);
 }
 setActuallyToBePreempted(Resources.max(rc, cluster,
   getActuallyToBePreempted(), Resources.none()));
}

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

private void verifyContainerAllocated(CSAssignment assignment, NodeType nodeType) {
 Assert.assertTrue(Resources.greaterThan(resourceCalculator, null,
   assignment.getResource(), Resources.none()));
 Assert
   .assertTrue(assignment.getAssignmentInformation().getNumAllocations() > 0);
 Assert.assertEquals(nodeType, assignment.getType());
}

内容来源于网络，如有侵权，请联系作者删除！

resources

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com