import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionResourceRequestProto; //导入依赖的package包/类
private void initPreemptionResourceRequests() {
  if (resources != null) {
    return;
  }
  PreemptionContractProtoOrBuilder p = viaProto ? proto : builder;
  List<PreemptionResourceRequestProto> list = p.getResourceList();
  resources = new ArrayList<PreemptionResourceRequest>();

  for (PreemptionResourceRequestProto rr : list) {
    resources.add(convertFromProtoFormat(rr));
  }
}
 

import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionResourceRequestProto; //导入依赖的package包/类
private void addResourcesToProto() {
  maybeInitBuilder();
  builder.clearResource();
  if (null == resources) {
    return;
  }
  Iterable<PreemptionResourceRequestProto> iterable =
    new Iterable<PreemptionResourceRequestProto>() {
    @Override
    public Iterator<PreemptionResourceRequestProto> iterator() {
      return new Iterator<PreemptionResourceRequestProto>() {

        Iterator<PreemptionResourceRequest> iter = resources.iterator();

        @Override
        public boolean hasNext() {
          return iter.hasNext();
        }

        @Override
        public PreemptionResourceRequestProto next() {
          return convertToProtoFormat(iter.next());
        }

        @Override
        public void remove() {
          throw new UnsupportedOperationException();

        }
      };

    }
  };
  builder.addAllResource(iterable);
}
 

import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionResourceRequestProto; //导入依赖的package包/类
public PreemptionResourceRequestPBImpl() {
  builder = PreemptionResourceRequestProto.newBuilder();
}
 

import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionResourceRequestProto; //导入依赖的package包/类
public synchronized PreemptionResourceRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}
 

import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionResourceRequestProto; //导入依赖的package包/类
private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = PreemptionResourceRequestProto.newBuilder(proto);
  }
  viaProto = false;
}
 

import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionResourceRequestProto; //导入依赖的package包/类
private PreemptionResourceRequestPBImpl convertFromProtoFormat(PreemptionResourceRequestProto p) {
  return new PreemptionResourceRequestPBImpl(p);
}
 

import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionResourceRequestProto; //导入依赖的package包/类
private PreemptionResourceRequestProto convertToProtoFormat(PreemptionResourceRequest t) {
  return ((PreemptionResourceRequestPBImpl)t).getProto();
}
 

import org.apache.hadoop.yarn.proto.YarnProtos.PreemptionResourceRequestProto; //导入依赖的package包/类
@Test
public void testPreemptionResourceRequestPBImpl() throws Exception {
  validatePBImplRecord(PreemptionResourceRequestPBImpl.class,
      PreemptionResourceRequestProto.class);
}