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

本文整理了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());
}
}
}