import org.apache.hadoop.yarn.proto.YarnProtos.ContainerResourceDecreaseProto; //导入依赖的package包/类
private synchronized void initLocalDecreasedContainerList() {
  if (this.decreasedContainers != null) {
    return;
  }
  AllocateResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<ContainerResourceDecreaseProto> list = p.getDecreasedContainersList();
  decreasedContainers = new ArrayList<ContainerResourceDecrease>();

  for (ContainerResourceDecreaseProto c : list) {
    decreasedContainers.add(convertFromProtoFormat(c));
  }
}
 

import org.apache.hadoop.yarn.proto.YarnProtos.ContainerResourceDecreaseProto; //导入依赖的package包/类
private synchronized Iterable<ContainerResourceDecreaseProto>
    getChangeProtoIterable(
        final List<ContainerResourceDecrease> newContainersList) {
  maybeInitBuilder();
  return new Iterable<ContainerResourceDecreaseProto>() {
    @Override
    public synchronized Iterator<ContainerResourceDecreaseProto> iterator() {
      return new Iterator<ContainerResourceDecreaseProto>() {

        Iterator<ContainerResourceDecrease> iter = newContainersList
            .iterator();

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

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

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

    }
  };
}
 

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

import org.apache.hadoop.yarn.proto.YarnProtos.ContainerResourceDecreaseProto; //导入依赖的package包/类
private synchronized ContainerResourceDecreaseProto convertToProtoFormat(
    ContainerResourceDecrease t) {
  return ((ContainerResourceDecreasePBImpl) t).getProto();
}
 

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

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

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