org.apache.hadoop.yarn.api.records.Resource.compareTo()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(7.8k)|赞(0)|评价(0)|浏览(87)

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

Resource.compareTo介绍

暂无

代码示例

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

public int compare(Resource res0, Resource res1) {
  return res1.compareTo(res0);
 }
}

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

@Override
 public int compare(ReservationAllocation lhs, ReservationAllocation rhs) {
  // compute delta between current and previous reservation, and compare
  // based on that
  Resource lhsRes = getUnallocatedReservedResources(lhs);
  Resource rhsRes = getUnallocatedReservedResources(rhs);
  return lhsRes.compareTo(rhsRes);
 }
}

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

@Override
 public int compare(ReservationAllocation lhs, ReservationAllocation rhs) {
  // compute delta between current and previous reservation, and compare
  // based on that
  Resource lhsRes = getUnallocatedReservedResources(lhs);
  Resource rhsRes = getUnallocatedReservedResources(rhs);
  return lhsRes.compareTo(rhsRes);
 }
}

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

@Override
 public int compare(ReservationAllocation lhs, ReservationAllocation rhs) {
  // compute delta between current and previous reservation, and compare
  // based on that
  Resource lhsRes = getUnallocatedReservedResources(lhs);
  Resource rhsRes = getUnallocatedReservedResources(rhs);
  return lhsRes.compareTo(rhsRes);
 }
}

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

@Override
 public int compare(N o1, N o2) {
  int allocatedDiff = o1.getAllocatedResource()
    .compareTo(o2.getAllocatedResource());
  if (allocatedDiff == 0) {
   return o1.getNodeID().compareTo(o2.getNodeID());
  }
  return allocatedDiff;
 }
};

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

@Override
 public int compare(ResourceRequest r1, ResourceRequest r2) {
  // Compare priority, host and capability
  int ret = r1.getPriority().compareTo(r2.getPriority());
  if (ret == 0) {
   String h1 = r1.getResourceName();
   String h2 = r2.getResourceName();
   ret = h1.compareTo(h2);
  }
  if (ret == 0) {
   ret = r1.getCapability().compareTo(r2.getCapability());
  }
  return ret;
 }
}

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

@Override
 public int compare(ResourceRequest r1, ResourceRequest r2) {
  // Compare priority, host and capability
  int ret = r1.getPriority().compareTo(r2.getPriority());
  if (ret == 0) {
   String h1 = r1.getResourceName();
   String h2 = r2.getResourceName();
   ret = h1.compareTo(h2);
  }
  if (ret == 0) {
   ret = r1.getCapability().compareTo(r2.getCapability());
  }
  return ret;
 }
}

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

@Override
 public int compare(ReservationRequest r1, ReservationRequest r2) {
  // Compare numContainers, concurrency and capability
  int ret = r1.getNumContainers() - r2.getNumContainers();
  if (ret == 0) {
   ret = r1.getConcurrency() - r2.getConcurrency();
  }
  if (ret == 0) {
   ret = r1.getCapability().compareTo(r2.getCapability());
  }
  return ret;
 }
}

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

@Override
 public int compare(ReservationRequest r1, ReservationRequest r2) {
  // Compare numContainers, concurrency and capability
  int ret = r1.getNumContainers() - r2.getNumContainers();
  if (ret == 0) {
   ret = r1.getConcurrency() - r2.getConcurrency();
  }
  if (ret == 0) {
   ret = r1.getCapability().compareTo(r2.getCapability());
  }
  return ret;
 }
}

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

@Override
 public int compare(ReservationRequest r1, ReservationRequest r2) {
  // Compare numContainers, concurrency and capability
  int ret = r1.getNumContainers() - r2.getNumContainers();
  if (ret == 0) {
   ret = r1.getConcurrency() - r2.getConcurrency();
  }
  if (ret == 0) {
   ret = r1.getCapability().compareTo(r2.getCapability());
  }
  return ret;
 }
}

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

@Override
 public int compare(ReservationRequest r1, ReservationRequest r2) {
  // Compare numContainers, concurrency and capability
  int ret = r1.getNumContainers() - r2.getNumContainers();
  if (ret == 0) {
   ret = r1.getConcurrency() - r2.getConcurrency();
  }
  if (ret == 0) {
   ret = r1.getCapability().compareTo(r2.getCapability());
  }
  return ret;
 }
}

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

@Override
public int compareTo(ReservationRequest other) {
 int numContainersComparison =
   this.getNumContainers() - other.getNumContainers();
 if (numContainersComparison == 0) {
  int concurrencyComparison =
    this.getConcurrency() - other.getConcurrency();
  if (concurrencyComparison == 0) {
   return this.getCapability().compareTo(other.getCapability());
  } else {
   return concurrencyComparison;
  }
 } else {
  return numContainersComparison;
 }
}

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

@Test(timeout = 10000)
public void testCompareToWithNoneResource() {
 assertTrue(Resources.none().compareTo(createResource(0, 0)) == 0);
 assertTrue(Resources.none().compareTo(createResource(1, 0)) < 0);
 assertTrue(Resources.none().compareTo(createResource(0, 1)) < 0);
 assertTrue(Resources.none().compareTo(createResource(0, 0, 0)) == 0);
 assertTrue(Resources.none().compareTo(createResource(1, 0, 0)) < 0);
 assertTrue(Resources.none().compareTo(createResource(0, 1, 0)) < 0);
 assertTrue(Resources.none().compareTo(createResource(0, 0, 1)) < 0);
}

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

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

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

@Test(timeout=10000)
 public void testCompareToWithNoneResource() {
  assertTrue(Resources.none().compareTo(createResource(0, 0, 0)) == 0);
  assertTrue(Resources.none().compareTo(
    createResource(1, 0, 0)) < 0);
  assertTrue(Resources.none().compareTo(
    createResource(0, 1, 0)) < 0);
  assertTrue(Resources.none().compareTo(
    createResource(0, 0, 1)) < 0);
 }
}

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

代码示例来源：origin: org.apache.reef/reef-runtime-yarn

private boolean isSameKindOfRequest(final AMRMClient.ContainerRequest r1, final AMRMClient.ContainerRequest r2) {
 return r1.getPriority().compareTo(r2.getPriority()) == 0
   && r1.getCapability().compareTo(r2.getCapability()) == 0
   && r1.getRelaxLocality() == r2.getRelaxLocality()
   && ListUtils.isEqualList(r1.getNodes(), r2.getNodes())
   && ListUtils.isEqualList(r1.getRacks(), r2.getRacks());
}

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

@Override
 public int compareTo(Container other) {
  if (this.getId().compareTo(other.getId()) == 0) {
   if (this.getNodeId().compareTo(other.getNodeId()) == 0) {
    return this.getResource().compareTo(other.getResource());
   } else {
    return this.getNodeId().compareTo(other.getNodeId());
   }
  } else {
   return this.getId().compareTo(other.getId());
  }
 }
}

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

@Override
 public int compareTo(Container other) {
  if (this.getId().compareTo(other.getId()) == 0) {
   if (this.getNodeId().compareTo(other.getNodeId()) == 0) {
    return this.getResource().compareTo(other.getResource());
   } else {
    return this.getNodeId().compareTo(other.getNodeId());
   }
  } else {
   return this.getId().compareTo(other.getId());
  }
 }
}

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

@Override
 public int compareTo(Container other) {
  if (this.getId().compareTo(other.getId()) == 0) {
   if (this.getNodeId().compareTo(other.getNodeId()) == 0) {
    return this.getResource().compareTo(other.getResource());
   } else {
    return this.getNodeId().compareTo(other.getNodeId());
   }
  } else {
   return this.getId().compareTo(other.getId());
  }
 }
}

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

Resource

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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