Java 类org.apache.hadoop.yarn.api.records.impl.pb.ContainerResourceIncreaseRequestPBImpl 实例源码

项目:hadoop    文件:TestContainerResourceIncreaseRequest.java   
@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);
}
项目:big-c    文件:TestContainerResourceIncreaseRequest.java   
@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);
}
项目:hadoop-2.6.0-cdh5.4.3    文件:TestContainerResourceIncreaseRequest.java   
@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);
}
项目:hadoop-on-lustre2    文件:TestContainerResourceIncreaseRequest.java   
@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);
}
项目:hadoop    文件:TestContainerResourceIncreaseRequest.java   
@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());
}
项目:big-c    文件:TestContainerResourceIncreaseRequest.java   
@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());
}
项目:hadoop-2.6.0-cdh5.4.3    文件:TestContainerResourceIncreaseRequest.java   
@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());
}
项目:hadoop-on-lustre2    文件:TestContainerResourceIncreaseRequest.java   
@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());
}
项目:hadoop    文件:AllocateRequestPBImpl.java   
private ContainerResourceIncreaseRequestPBImpl convertFromProtoFormat(
    ContainerResourceIncreaseRequestProto p) {
  return new ContainerResourceIncreaseRequestPBImpl(p);
}
项目:hadoop    文件:AllocateRequestPBImpl.java   
private ContainerResourceIncreaseRequestProto convertToProtoFormat(
    ContainerResourceIncreaseRequest t) {
  return ((ContainerResourceIncreaseRequestPBImpl) t).getProto();
}
项目:big-c    文件:AllocateRequestPBImpl.java   
private ContainerResourceIncreaseRequestPBImpl convertFromProtoFormat(
    ContainerResourceIncreaseRequestProto p) {
  return new ContainerResourceIncreaseRequestPBImpl(p);
}
项目:big-c    文件:AllocateRequestPBImpl.java   
private ContainerResourceIncreaseRequestProto convertToProtoFormat(
    ContainerResourceIncreaseRequest t) {
  return ((ContainerResourceIncreaseRequestPBImpl) t).getProto();
}
项目:hadoop-2.6.0-cdh5.4.3    文件:AllocateRequestPBImpl.java   
private ContainerResourceIncreaseRequestPBImpl convertFromProtoFormat(
    ContainerResourceIncreaseRequestProto p) {
  return new ContainerResourceIncreaseRequestPBImpl(p);
}
项目:hadoop-2.6.0-cdh5.4.3    文件:AllocateRequestPBImpl.java   
private ContainerResourceIncreaseRequestProto convertToProtoFormat(
    ContainerResourceIncreaseRequest t) {
  return ((ContainerResourceIncreaseRequestPBImpl) t).getProto();
}
项目:hops    文件:AllocateRequestPBImpl.java   
private ContainerResourceIncreaseRequestPBImpl convertFromProtoFormat(
    YarnProtos.ContainerResourceIncreaseRequestProto p) {
  return new ContainerResourceIncreaseRequestPBImpl(p);

}
项目:hops    文件:AllocateRequestPBImpl.java   
private YarnProtos.ContainerResourceIncreaseRequestProto convertToProtoFormat(
    ContainerResourceIncreaseRequest t) {
  return ((ContainerResourceIncreaseRequestPBImpl) t).getProto();

}
项目:hadoop-on-lustre2    文件:AllocateRequestPBImpl.java   
private ContainerResourceIncreaseRequestPBImpl convertFromProtoFormat(
    ContainerResourceIncreaseRequestProto p) {
  return new ContainerResourceIncreaseRequestPBImpl(p);
}
项目:hadoop-on-lustre2    文件:AllocateRequestPBImpl.java   
private ContainerResourceIncreaseRequestProto convertToProtoFormat(
    ContainerResourceIncreaseRequest t) {
  return ((ContainerResourceIncreaseRequestPBImpl) t).getProto();
}