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

public static ReservationAllocationStateProto buildStateProto(
    ReservationAllocation allocation) {
  ReservationAllocationStateProto.Builder builder =
      ReservationAllocationStateProto.newBuilder();

  builder.setAcceptanceTimestamp(allocation.getAcceptanceTime());
  builder.setContainsGangs(allocation.containsGangs());
  builder.setStartTime(allocation.getStartTime());
  builder.setEndTime(allocation.getEndTime());
  builder.setUser(allocation.getUser());
  ReservationDefinitionProto definitionProto = convertToProtoFormat(
      allocation.getReservationDefinition());
  builder.setReservationDefinition(definitionProto);

  for (Map.Entry<ReservationInterval, Resource> entry :
      allocation.getAllocationRequests().entrySet()) {
    ResourceAllocationRequestProto p =
        ResourceAllocationRequestProto.newBuilder()
        .setStartTime(entry.getKey().getStartTime())
        .setEndTime(entry.getKey().getEndTime())
        .setResource(convertToProtoFormat(entry.getValue()))
        .build();
    builder.addAllocationRequests(p);
  }

  ReservationAllocationStateProto allocationProto = builder.build();
  return allocationProto;
}

public static ReservationAllocationStateProto buildStateProto(
    ReservationAllocation allocation) {
  ReservationAllocationStateProto.Builder builder =
      ReservationAllocationStateProto.newBuilder();

  builder.setAcceptanceTime(allocation.getAcceptanceTime());
  builder.setContainsGangs(allocation.containsGangs());
  builder.setStartTime(allocation.getStartTime());
  builder.setEndTime(allocation.getEndTime());
  builder.setUser(allocation.getUser());
  ReservationDefinitionProto definitionProto = convertToProtoFormat(
      allocation.getReservationDefinition());
  builder.setReservationDefinition(definitionProto);

  for (Map.Entry<ReservationInterval, Resource> entry :
      allocation.getAllocationRequests().entrySet()) {
    ResourceAllocationRequestProto p =
        ResourceAllocationRequestProto.newBuilder()
        .setStartTime(entry.getKey().getStartTime())
        .setEndTime(entry.getKey().getEndTime())
        .setResource(convertToProtoFormat(entry.getValue()))
        .build();
    builder.addAllocationRequests(p);
  }

  ReservationAllocationStateProto allocationProto = builder.build();
  return allocationProto;
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

public ReservationDefinitionPBImpl() {
  builder = ReservationDefinitionProto.newBuilder();
}

public ReservationDefinitionPBImpl(ReservationDefinitionProto proto) {
  this.proto = proto;
  viaProto = true;
}

public ReservationDefinitionProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationDefinitionProto.newBuilder(proto);
  }
  viaProto = false;
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

public ReservationDefinitionPBImpl() {
  builder = ReservationDefinitionProto.newBuilder();
}

public ReservationDefinitionPBImpl(ReservationDefinitionProto proto) {
  this.proto = proto;
  viaProto = true;
}

public ReservationDefinitionProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationDefinitionProto.newBuilder(proto);
  }
  viaProto = false;
}

private static ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition reservationDefinition) {
  return ((ReservationDefinitionPBImpl)reservationDefinition).getProto();
}

public static ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

public ReservationDefinitionPBImpl() {
  builder = ReservationDefinitionProto.newBuilder();
}

public ReservationDefinitionPBImpl(ReservationDefinitionProto proto) {
  this.proto = proto;
  viaProto = true;
}

public ReservationDefinitionProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationDefinitionProto.newBuilder(proto);
  }
  viaProto = false;
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

public ReservationDefinitionPBImpl() {
  builder = ReservationDefinitionProto.newBuilder();
}

public ReservationDefinitionPBImpl(ReservationDefinitionProto proto) {
  this.proto = proto;
  viaProto = true;
}

public ReservationDefinitionProto getProto() {
  mergeLocalToProto();
  proto = viaProto ? proto : builder.build();
  viaProto = true;
  return proto;
}

private void maybeInitBuilder() {
  if (viaProto || builder == null) {
    builder = ReservationDefinitionProto.newBuilder(proto);
  }
  viaProto = false;
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}

private ReservationDefinitionProto convertToProtoFormat(
    ReservationDefinition r) {
  return ((ReservationDefinitionPBImpl) r).getProto();
}

private ReservationDefinitionPBImpl convertFromProtoFormat(
    ReservationDefinitionProto r) {
  return new ReservationDefinitionPBImpl(r);
}