本文整理汇总了Java中org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest类的典型用法代码示例。如果您正苦于以下问题：Java ContainerResourceIncreaseRequest类的具体用法？Java ContainerResourceIncreaseRequest怎么用？Java ContainerResourceIncreaseRequest使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ContainerResourceIncreaseRequest类属于org.apache.hadoop.yarn.api.records包，在下文中一共展示了ContainerResourceIncreaseRequest类的18个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: ContainerResourceIncreaseRequest
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@Test
public void ContainerResourceIncreaseRequest() {
ContainerId containerId = ContainerId
.newContainerId(ApplicationAttemptId.newInstance(
ApplicationId.newInstance(1234, 3), 3), 7);
Resource resource = Resource.newInstance(1023, 3, 4);
ContainerResourceIncreaseRequest context = ContainerResourceIncreaseRequest
.newInstance(containerId, resource);
// to proto and get it back
ContainerResourceIncreaseRequestProto proto =
((ContainerResourceIncreaseRequestPBImpl) context).getProto();
ContainerResourceIncreaseRequest contextRecover =
new ContainerResourceIncreaseRequestPBImpl(proto);
// check value
Assert.assertEquals(contextRecover.getContainerId(), containerId);
Assert.assertEquals(contextRecover.getCapability(), resource);
}
开发者ID:naver，项目名称:hadoop，代码行数:20，代码来源:TestContainerResourceIncreaseRequest.java
示例2: newInstance
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@Public
@Stable
public static AllocateRequest newInstance(int responseID, float appProgress,
List<ResourceRequest> resourceAsk,
List<ContainerId> containersToBeReleased,
ResourceBlacklistRequest resourceBlacklistRequest,
List<ContainerResourceIncreaseRequest> increaseRequests) {
AllocateRequest allocateRequest = Records.newRecord(AllocateRequest.class);
allocateRequest.setResponseId(responseID);
allocateRequest.setProgress(appProgress);
allocateRequest.setAskList(resourceAsk);
allocateRequest.setReleaseList(containersToBeReleased);
allocateRequest.setResourceBlacklistRequest(resourceBlacklistRequest);
allocateRequest.setIncreaseRequests(increaseRequests);
return allocateRequest;
}
开发者ID:naver，项目名称:hadoop，代码行数:17，代码来源:AllocateRequest.java
示例3: ContainerResourceIncreaseRequest
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@Test
public void ContainerResourceIncreaseRequest() {
ContainerId containerId = ContainerId
.newContainerId(ApplicationAttemptId.newInstance(
ApplicationId.newInstance(1234, 3), 3), 7);
Resource resource = Resource.newInstance(1023, 3);
ContainerResourceIncreaseRequest context = ContainerResourceIncreaseRequest
.newInstance(containerId, resource);
// to proto and get it back
ContainerResourceIncreaseRequestProto proto =
((ContainerResourceIncreaseRequestPBImpl) context).getProto();
ContainerResourceIncreaseRequest contextRecover =
new ContainerResourceIncreaseRequestPBImpl(proto);
// check value
Assert.assertEquals(contextRecover.getContainerId(), containerId);
Assert.assertEquals(contextRecover.getCapability(), resource);
}
开发者ID:yncxcw，项目名称:big-c，代码行数:20，代码来源:TestContainerResourceIncreaseRequest.java
示例4: newInstance
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
/**
* Use {@link AllocateRequest#newInstance(int, float, List, List,
* ResourceBlacklistRequest, List)} instead
* @param responseID responseId
* @param appProgress appProgress
* @param resourceAsk resourceAsk
* @param containersToBeReleased containersToBeReleased
* @param resourceBlacklistRequest resourceBlacklistRequest
* @param increaseRequests increaseRequests
* @return AllocateRequest
*/
@Deprecated
public static AllocateRequest newInstance(int responseID, float appProgress,
List<ResourceRequest> resourceAsk,
List<ContainerId> containersToBeReleased,
ResourceBlacklistRequest resourceBlacklistRequest,
List<ContainerResourceIncreaseRequest> increaseRequests) {
AllocateRequest allocateRequest = Records.newRecord(AllocateRequest.class);
allocateRequest.setResponseId(responseID);
allocateRequest.setProgress(appProgress);
allocateRequest.setAskList(resourceAsk);
allocateRequest.setReleaseList(containersToBeReleased);
allocateRequest.setResourceBlacklistRequest(resourceBlacklistRequest);
allocateRequest.setIncreaseRequests(increaseRequests);
return allocateRequest;
}
开发者ID:hopshadoop，项目名称:hops，代码行数:27，代码来源:AllocateRequest.java
示例5: ContainerResourceIncreaseRequest
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@Test
public void ContainerResourceIncreaseRequest() {
ContainerId containerId = ContainerId
.newInstance(ApplicationAttemptId.newInstance(
ApplicationId.newInstance(1234, 3), 3), 7);
Resource resource = Resource.newInstance(1023, 3);
ContainerResourceIncreaseRequest context = ContainerResourceIncreaseRequest
.newInstance(containerId, resource);
// to proto and get it back
ContainerResourceIncreaseRequestProto proto =
((ContainerResourceIncreaseRequestPBImpl) context).getProto();
ContainerResourceIncreaseRequest contextRecover =
new ContainerResourceIncreaseRequestPBImpl(proto);
// check value
Assert.assertEquals(contextRecover.getContainerId(), containerId);
Assert.assertEquals(contextRecover.getCapability(), resource);
}
开发者ID:Seagate，项目名称:hadoop-on-lustre2，代码行数:20，代码来源:TestContainerResourceIncreaseRequest.java
示例6: setIncreaseRequests
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@Override
public void setIncreaseRequests(
List<ContainerResourceIncreaseRequest> increaseRequests) {
if (increaseRequests == null) {
return;
}
initIncreaseRequests();
this.increaseRequests.clear();
this.increaseRequests.addAll(increaseRequests);
}
开发者ID:naver，项目名称:hadoop，代码行数:11，代码来源:AllocateRequestPBImpl.java
示例7: initIncreaseRequests
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
private void initIncreaseRequests() {
if (this.increaseRequests != null) {
return;
}
AllocateRequestProtoOrBuilder p = viaProto ? proto : builder;
List<ContainerResourceIncreaseRequestProto> list =
p.getIncreaseRequestList();
this.increaseRequests = new ArrayList<ContainerResourceIncreaseRequest>();
for (ContainerResourceIncreaseRequestProto c : list) {
this.increaseRequests.add(convertFromProtoFormat(c));
}
}
开发者ID:naver，项目名称:hadoop，代码行数:14，代码来源:AllocateRequestPBImpl.java
示例8: addIncreaseRequestsToProto
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
private void addIncreaseRequestsToProto() {
maybeInitBuilder();
builder.clearIncreaseRequest();
if (increaseRequests == null) {
return;
}
Iterable<ContainerResourceIncreaseRequestProto> iterable =
new Iterable<ContainerResourceIncreaseRequestProto>() {
@Override
public Iterator<ContainerResourceIncreaseRequestProto> iterator() {
return new Iterator<ContainerResourceIncreaseRequestProto>() {
Iterator<ContainerResourceIncreaseRequest> iter =
increaseRequests.iterator();
@Override
public boolean hasNext() {
return iter.hasNext();
}
@Override
public ContainerResourceIncreaseRequestProto next() {
return convertToProtoFormat(iter.next());
}
@Override
public void remove() {
throw new UnsupportedOperationException();
}
};
}
};
builder.addAllIncreaseRequest(iterable);
}
开发者ID:naver，项目名称:hadoop，代码行数:36，代码来源:AllocateRequestPBImpl.java
示例9: testResourceChangeContextWithNullField
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@Test
public void testResourceChangeContextWithNullField() {
ContainerResourceIncreaseRequest context = ContainerResourceIncreaseRequest
.newInstance(null, null);
// to proto and get it back
ContainerResourceIncreaseRequestProto proto =
((ContainerResourceIncreaseRequestPBImpl) context).getProto();
ContainerResourceIncreaseRequest contextRecover =
new ContainerResourceIncreaseRequestPBImpl(proto);
// check value
Assert.assertNull(contextRecover.getContainerId());
Assert.assertNull(contextRecover.getCapability());
}
开发者ID:naver，项目名称:hadoop，代码行数:16，代码来源:TestContainerResourceIncreaseRequest.java
示例10: addIncreaseRequestsToProto
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
private void addIncreaseRequestsToProto() {
maybeInitBuilder();
builder.clearIncreaseRequest();
if (deprecatedIncreaseReqs == null) {
return;
}
Iterable<YarnProtos.ContainerResourceIncreaseRequestProto> iterable =
new Iterable<YarnProtos.ContainerResourceIncreaseRequestProto>() {
@Override
public Iterator<YarnProtos.ContainerResourceIncreaseRequestProto> iterator() {
return new Iterator<YarnProtos.ContainerResourceIncreaseRequestProto>() {
private Iterator<ContainerResourceIncreaseRequest> iter =
deprecatedIncreaseReqs.iterator();
@Override
public boolean hasNext() {
return iter.hasNext();
}
@Override
public YarnProtos.ContainerResourceIncreaseRequestProto next() {
return convertToProtoFormat(iter.next());
}
@Override
public void remove() {
throw new UnsupportedOperationException();
}
};
}
};
builder.addAllIncreaseRequest(iterable);
}
开发者ID:hopshadoop，项目名称:hops，代码行数:36，代码来源:AllocateRequestPBImpl.java
示例11: setIncreaseRequests
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@Deprecated
@Override
public void setIncreaseRequests(
List<ContainerResourceIncreaseRequest> increaseRequests) {
if (increaseRequests == null) {
return;
}
initIncreaseRequests();
this.deprecatedIncreaseReqs.clear();
this.deprecatedIncreaseReqs.addAll(increaseRequests);
}
开发者ID:hopshadoop，项目名称:hops，代码行数:12，代码来源:AllocateRequestPBImpl.java
示例12: getIncreaseRequests
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@Override
public List<ContainerResourceIncreaseRequest> getIncreaseRequests() {
initIncreaseRequests();
return this.increaseRequests;
}
开发者ID:naver，项目名称:hadoop，代码行数:6，代码来源:AllocateRequestPBImpl.java
示例13: convertToProtoFormat
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
private ContainerResourceIncreaseRequestProto convertToProtoFormat(
ContainerResourceIncreaseRequest t) {
return ((ContainerResourceIncreaseRequestPBImpl) t).getProto();
}
开发者ID:naver，项目名称:hadoop，代码行数:5，代码来源:AllocateRequestPBImpl.java
示例14: getIncreaseRequests
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@Deprecated
@Override
public List<ContainerResourceIncreaseRequest> getIncreaseRequests() {
initIncreaseRequests();
return this.deprecatedIncreaseReqs;
}
开发者ID:hopshadoop，项目名称:hops，代码行数:7，代码来源:AllocateRequestPBImpl.java
示例15: convertToProtoFormat
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
private YarnProtos.ContainerResourceIncreaseRequestProto convertToProtoFormat(
ContainerResourceIncreaseRequest t) {
return ((ContainerResourceIncreaseRequestPBImpl) t).getProto();
}
开发者ID:hopshadoop，项目名称:hops，代码行数:6，代码来源:AllocateRequestPBImpl.java
示例16: setup
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
@BeforeClass
public static void setup() throws Exception {
typeValueCache.put(LongRange.class, new LongRange(1000, 2000));
typeValueCache.put(URL.class, URL.newInstance(
"http", "localhost", 8080, "file0"));
typeValueCache.put(SerializedException.class,
SerializedException.newInstance(new IOException("exception for test")));
generateByNewInstance(LogAggregationContext.class);
generateByNewInstance(ApplicationId.class);
generateByNewInstance(ApplicationAttemptId.class);
generateByNewInstance(ContainerId.class);
generateByNewInstance(Resource.class);
generateByNewInstance(ResourceBlacklistRequest.class);
generateByNewInstance(ResourceOption.class);
generateByNewInstance(LocalResource.class);
generateByNewInstance(Priority.class);
generateByNewInstance(NodeId.class);
generateByNewInstance(NodeReport.class);
generateByNewInstance(Token.class);
generateByNewInstance(NMToken.class);
generateByNewInstance(ResourceRequest.class);
generateByNewInstance(ApplicationAttemptReport.class);
generateByNewInstance(ApplicationResourceUsageReport.class);
generateByNewInstance(ApplicationReport.class);
generateByNewInstance(Container.class);
generateByNewInstance(ContainerLaunchContext.class);
generateByNewInstance(ApplicationSubmissionContext.class);
generateByNewInstance(ContainerReport.class);
generateByNewInstance(UpdateContainerRequest.class);
generateByNewInstance(UpdateContainerError.class);
generateByNewInstance(IncreaseContainersResourceRequest.class);
generateByNewInstance(IncreaseContainersResourceResponse.class);
generateByNewInstance(ContainerStatus.class);
generateByNewInstance(PreemptionContainer.class);
generateByNewInstance(PreemptionResourceRequest.class);
generateByNewInstance(PreemptionContainer.class);
generateByNewInstance(PreemptionContract.class);
generateByNewInstance(StrictPreemptionContract.class);
generateByNewInstance(PreemptionMessage.class);
generateByNewInstance(StartContainerRequest.class);
generateByNewInstance(NodeLabel.class);
generateByNewInstance(UpdatedContainer.class);
// genByNewInstance does not apply to QueueInfo, cause
// it is recursive(has sub queues)
typeValueCache.put(QueueInfo.class, QueueInfo.newInstance("root", 1.0f,
1.0f, 0.1f, null, null, QueueState.RUNNING, ImmutableSet.of("x", "y"),
"x && y", null, false));
generateByNewInstance(QueueStatistics.class);
generateByNewInstance(QueueUserACLInfo.class);
generateByNewInstance(YarnClusterMetrics.class);
// for reservation system
generateByNewInstance(ReservationId.class);
generateByNewInstance(ReservationRequest.class);
generateByNewInstance(ReservationRequests.class);
generateByNewInstance(ReservationDefinition.class);
generateByNewInstance(ResourceAllocationRequest.class);
generateByNewInstance(ReservationAllocationState.class);
generateByNewInstance(ResourceUtilization.class);
generateByNewInstance(ContainerResourceIncreaseRequest.class);
}
开发者ID:hopshadoop，项目名称:hops，代码行数:61，代码来源:TestPBImplRecords.java
示例17: getIncreaseRequests
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
/**
* Get the <code>ContainerResourceIncreaseRequest</code> being sent by the
* <code>ApplicationMaster</code>
*/
@Public
@Stable
public abstract List<ContainerResourceIncreaseRequest> getIncreaseRequests();
开发者ID:naver，项目名称:hadoop，代码行数:8，代码来源:AllocateRequest.java
示例18: setIncreaseRequests
import org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest; //导入依赖的package包/类
/**
* Set the <code>ContainerResourceIncreaseRequest</code> to inform the
* <code>ResourceManager</code> about some container's resources need to be
* increased
*/
@Public
@Stable
public abstract void setIncreaseRequests(
List<ContainerResourceIncreaseRequest> increaseRequests);
开发者ID:naver，项目名称:hadoop，代码行数:10，代码来源:AllocateRequest.java
注：本文中的org.apache.hadoop.yarn.api.records.ContainerResourceIncreaseRequest类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论