Java 类org.apache.hadoop.yarn.proto.YarnProtos.ReservationRequestProto 实例源码

项目:hadoop    文件:ReservationRequestsPBImpl.java   
private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}
项目:hadoop    文件:ReservationRequestsPBImpl.java   
private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

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

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

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

          };

        }

      };
  builder.addAllReservationResources(iterable);
}
项目:aliyun-oss-hadoop-fs    文件:ReservationRequestsPBImpl.java   
private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}
项目:aliyun-oss-hadoop-fs    文件:ReservationRequestsPBImpl.java   
private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

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

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

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

          };

        }

      };
  builder.addAllReservationResources(iterable);
}
项目:big-c    文件:ReservationRequestsPBImpl.java   
private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}
项目:big-c    文件:ReservationRequestsPBImpl.java   
private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

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

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

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

          };

        }

      };
  builder.addAllReservationResources(iterable);
}
项目:hadoop-2.6.0-cdh5.4.3    文件:ReservationRequestsPBImpl.java   
private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}
项目:hadoop-2.6.0-cdh5.4.3    文件:ReservationRequestsPBImpl.java   
private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

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

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

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

          };

        }

      };
  builder.addAllReservationResources(iterable);
}
项目:hops    文件:ReservationRequestsPBImpl.java   
private void initReservationRequestsList() {
  if (this.reservationRequests != null) {
    return;
  }
  ReservationRequestsProtoOrBuilder p = viaProto ? proto : builder;
  List<ReservationRequestProto> resourceProtos =
      p.getReservationResourcesList();
  reservationRequests = new ArrayList<ReservationRequest>();

  for (ReservationRequestProto r : resourceProtos) {
    reservationRequests.add(convertFromProtoFormat(r));
  }
}
项目:hops    文件:ReservationRequestsPBImpl.java   
private void addReservationResourcesToProto() {
  maybeInitBuilder();
  builder.clearReservationResources();
  if (reservationRequests == null)
    return;
  Iterable<ReservationRequestProto> iterable =
      new Iterable<ReservationRequestProto>() {
        @Override
        public Iterator<ReservationRequestProto> iterator() {
          return new Iterator<ReservationRequestProto>() {

            Iterator<ReservationRequest> iter = reservationRequests
                .iterator();

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

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

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

          };

        }

      };
  builder.addAllReservationResources(iterable);
}
项目:hadoop    文件:ReservationRequestsPBImpl.java   
private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}
项目:hadoop    文件:ReservationRequestsPBImpl.java   
private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}
项目:hadoop    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}
项目:hadoop    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}
项目:hadoop    文件:ReservationRequestPBImpl.java   
public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}
项目:hadoop    文件:ReservationRequestPBImpl.java   
private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}
项目:aliyun-oss-hadoop-fs    文件:ReservationRequestsPBImpl.java   
private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}
项目:aliyun-oss-hadoop-fs    文件:ReservationRequestsPBImpl.java   
private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}
项目:aliyun-oss-hadoop-fs    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}
项目:aliyun-oss-hadoop-fs    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}
项目:aliyun-oss-hadoop-fs    文件:ReservationRequestPBImpl.java   
public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}
项目:aliyun-oss-hadoop-fs    文件:ReservationRequestPBImpl.java   
private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}
项目:big-c    文件:ReservationRequestsPBImpl.java   
private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}
项目:big-c    文件:ReservationRequestsPBImpl.java   
private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}
项目:big-c    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}
项目:big-c    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}
项目:big-c    文件:ReservationRequestPBImpl.java   
public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}
项目:big-c    文件:ReservationRequestPBImpl.java   
private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:ReservationRequestsPBImpl.java   
private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}
项目:hadoop-2.6.0-cdh5.4.3    文件:ReservationRequestsPBImpl.java   
private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}
项目:hadoop-2.6.0-cdh5.4.3    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}
项目:hadoop-2.6.0-cdh5.4.3    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:ReservationRequestPBImpl.java   
public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:ReservationRequestPBImpl.java   
private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}
项目:hops    文件:ReservationRequestsPBImpl.java   
private ReservationRequestProto convertToProtoFormat(ReservationRequest r) {
  return ((ReservationRequestPBImpl) r).getProto();
}
项目:hops    文件:ReservationRequestsPBImpl.java   
private ReservationRequestPBImpl convertFromProtoFormat(
    ReservationRequestProto r) {
  return new ReservationRequestPBImpl(r);
}
项目:hops    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl() {
  builder = ReservationRequestProto.newBuilder();
}
项目:hops    文件:ReservationRequestPBImpl.java   
public ReservationRequestPBImpl(ReservationRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}
项目:hops    文件:ReservationRequestPBImpl.java   
public ReservationRequestProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}
项目:hops    文件:ReservationRequestPBImpl.java   
private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationRequestProto.newBuilder(proto);
  }
  viaProto = false;
}