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

private RecoveredContainerState loadContainerState(ContainerId containerId,
    LeveldbIterator iter, String keyPrefix) throws IOException {
  RecoveredContainerState rcs = new RecoveredContainerState();
  rcs.status = RecoveredContainerStatus.REQUESTED;
  while (iter.hasNext()) {
    Entry<byte[],byte[]> entry = iter.peekNext();
    String key = asString(entry.getKey());
    if (!key.startsWith(keyPrefix)) {
      break;
    }
    iter.next();

    String suffix = key.substring(keyPrefix.length()-1);  // start with '/'
    if (suffix.equals(CONTAINER_REQUEST_KEY_SUFFIX)) {
      rcs.startRequest = new StartContainerRequestPBImpl(
          StartContainerRequestProto.parseFrom(entry.getValue()));
    } else if (suffix.equals(CONTAINER_DIAGS_KEY_SUFFIX)) {
      rcs.diagnostics = asString(entry.getValue());
    } else if (suffix.equals(CONTAINER_LAUNCHED_KEY_SUFFIX)) {
      if (rcs.status == RecoveredContainerStatus.REQUESTED) {
        rcs.status = RecoveredContainerStatus.LAUNCHED;
      }
    } else if (suffix.equals(CONTAINER_KILLED_KEY_SUFFIX)) {
      rcs.killed = true;
    } else if (suffix.equals(CONTAINER_EXIT_CODE_KEY_SUFFIX)) {
      rcs.status = RecoveredContainerStatus.COMPLETED;
      rcs.exitCode = Integer.parseInt(asString(entry.getValue()));
    } else if (suffix.equals(CONTAINER_RESOURCE_CHANGED_KEY_SUFFIX)) {
      rcs.capability = new ResourcePBImpl(
          ResourceProto.parseFrom(entry.getValue()));
    } else {
      throw new IOException("Unexpected container state key: " + key);
    }
  }
  return rcs;
}

private RecoveredContainerState loadContainerState(ContainerId containerId,
    LeveldbIterator iter, String keyPrefix) throws IOException {
  RecoveredContainerState rcs = new RecoveredContainerState();
  rcs.status = RecoveredContainerStatus.REQUESTED;
  while (iter.hasNext()) {
    Entry<byte[],byte[]> entry = iter.peekNext();
    String key = asString(entry.getKey());
    if (!key.startsWith(keyPrefix)) {
      break;
    }
    iter.next();

    String suffix = key.substring(keyPrefix.length()-1);  // start with '/'
    if (suffix.equals(CONTAINER_REQUEST_KEY_SUFFIX)) {
      rcs.startRequest = new StartContainerRequestPBImpl(
          StartContainerRequestProto.parseFrom(entry.getValue()));
    } else if (suffix.equals(CONTAINER_VERSION_KEY_SUFFIX)) {
      rcs.version = Integer.parseInt(asString(entry.getValue()));
    } else if (suffix.equals(CONTAINER_DIAGS_KEY_SUFFIX)) {
      rcs.diagnostics = asString(entry.getValue());
    } else if (suffix.equals(CONTAINER_LAUNCHED_KEY_SUFFIX)) {
      if (rcs.status == RecoveredContainerStatus.REQUESTED) {
        rcs.status = RecoveredContainerStatus.LAUNCHED;
      }
    } else if (suffix.equals(CONTAINER_KILLED_KEY_SUFFIX)) {
      rcs.killed = true;
    } else if (suffix.equals(CONTAINER_EXIT_CODE_KEY_SUFFIX)) {
      rcs.status = RecoveredContainerStatus.COMPLETED;
      rcs.exitCode = Integer.parseInt(asString(entry.getValue()));
    } else if (suffix.equals(CONTAINER_RESOURCE_CHANGED_KEY_SUFFIX)) {
      rcs.capability = new ResourcePBImpl(
          ResourceProto.parseFrom(entry.getValue()));
    } else {
      throw new IOException("Unexpected container state key: " + key);
    }
  }
  return rcs;
}

private Resource convertFromProtoFormat(ResourceProto resource) {
  return new ResourcePBImpl(resource);
}

private ResourceProto convertToProtoFormat(Resource resource) {
  return ((ResourcePBImpl)resource).getProto();
}

private Resource convertFromProtoFormat(ResourceProto resource) {
 return new ResourcePBImpl(resource);
}

private ResourceProto convertToProtoFormat(Resource resource) {
 return ((ResourcePBImpl)resource).getProto();
}

private synchronized ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private synchronized ResourceProto convertToProtoFormat(Resource r) {
  return ((ResourcePBImpl) r).getProto();
}

private Resource convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl) t).getProto();
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl)t).getProto();
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource r) {
  return ((ResourcePBImpl) r).getProto();
}

public ResourcePBImpl() {
  builder = ResourceProto.newBuilder();
}

public ResourcePBImpl(ResourceProto proto) {
  this.proto = proto;
  viaProto = true;
}

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

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

private ResourceProto convertToProtoFormat(
    Resource resource) {
  return ((ResourcePBImpl)resource).getProto();
}

private ResourcePBImpl convertFromProtoFormat(
    ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl)t).getProto();
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl)t).getProto();
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl) t).getProto();
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl)t).getProto();
}

private Resource convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl) t).getProto();
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl) t).getProto();
}

private Resource convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl) t).getProto();
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl) t).getProto();
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto p) {
  return new ResourcePBImpl(p);
}

private ResourceProto convertToProtoFormat(Resource t) {
  return ((ResourcePBImpl)t).getProto();
}

private ResourceProto convertToProtoFormat(Resource resource) {
  return ((ResourcePBImpl) resource).getProto();
}

private ResourcePBImpl convertFromProtoFormat(ResourceProto resource) {
  return new ResourcePBImpl(resource);
}