org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesResponseProto的实例源码

25-04-05 8

本文将分享org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesResponseProto的实例源码的详细

本文将分享org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesResponseProto的实例源码的详细内容，此外，我们还将为大家带来关于org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAccessTypeProto的实例源码、org.apache.hadoop.yarn.proto.YarnProtos.YarnApplicationStateProto的实例源码、org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProto的实例源码、org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto的实例源码的相关知识，希望对你有所帮助。

本文目录一览：

org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesResponseProto的实例源码
org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAccessTypeProto的实例源码
org.apache.hadoop.yarn.proto.YarnProtos.YarnApplicationStateProto的实例源码
org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProto的实例源码
org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto的实例源码

org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesResponseProto的实例源码

项目：hadoop 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl() {
  builder = MoveApplicationAcrossQueuesResponseProto.newBuilder();
}

项目：hadoop 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl(MoveApplicationAcrossQueuesResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl() {
  builder = MoveApplicationAcrossQueuesResponseProto.newBuilder();
}

项目：aliyun-oss-hadoop-fs 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl(MoveApplicationAcrossQueuesResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：aliyun-oss-hadoop-fs 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：TestPBImplRecords.java

@Test
public void testMoveApplicationAcrossQueuesResponsePBImpl() throws Exception {
  validatePBImplRecord(MoveApplicationAcrossQueuesResponsePBImpl.class,MoveApplicationAcrossQueuesResponseProto.class);
}

项目：big-c 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl() {
  builder = MoveApplicationAcrossQueuesResponseProto.newBuilder();
}

项目：big-c 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl(MoveApplicationAcrossQueuesResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：big-c 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

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

项目：hadoop-2.6.0-cdh5.4.3 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl() {
  builder = MoveApplicationAcrossQueuesResponseProto.newBuilder();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl(MoveApplicationAcrossQueuesResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

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

项目：hops 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl() {
  builder = MoveApplicationAcrossQueuesResponseProto.newBuilder();
}

项目：hops 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl(MoveApplicationAcrossQueuesResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hops 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

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

项目：hops 文件：TestPBImplRecords.java

@Test
public void testMoveApplicationAcrossQueuesResponsePBImpl() throws Exception {
  validatePBImplRecord(MoveApplicationAcrossQueuesResponsePBImpl.class,MoveApplicationAcrossQueuesResponseProto.class);
}

项目：hadoop-on-lustre2 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl() {
  builder = MoveApplicationAcrossQueuesResponseProto.newBuilder();
}

项目：hadoop-on-lustre2 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

public MoveApplicationAcrossQueuesResponsePBImpl(MoveApplicationAcrossQueuesResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-on-lustre2 文件：MoveApplicationAcrossQueuesResponsePBImpl.java

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

org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAccessTypeProto的实例源码

项目：hadoop 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：aliyun-oss-hadoop-fs 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：aliyun-oss-hadoop-fs 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：big-c 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：big-c 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hadoop-plus 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop-plus 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hops 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hops 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hadoop-TCP 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop-TCP 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hardfs 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hardfs 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

项目：hadoop-on-lustre2 文件：ProtoUtils.java

public static ApplicationAccesstypeProto convertToProtoFormat(
    ApplicationAccesstype e) {
  return ApplicationAccesstypeProto.valueOf(APP_ACCESS_TYPE_PREFIX
      + e.name());
}

项目：hadoop-on-lustre2 文件：ProtoUtils.java

public static ApplicationAccesstype convertFromProtoFormat(
    ApplicationAccesstypeProto e) {
  return ApplicationAccesstype.valueOf(e.name().replace(
      APP_ACCESS_TYPE_PREFIX,""));
}

org.apache.hadoop.yarn.proto.YarnProtos.YarnApplicationStateProto的实例源码

项目：hadoop 文件：GetApplicationsRequestPBImpl.java

private void initApplicationStates() {
  if (this.applicationStates != null) {
    return;
  }
  GetApplicationsRequestProtoOrBuilder p = viaProto ? proto : builder;
  List<YarnApplicationStateProto> appStatesList =
      p.getApplicationStatesList();
  this.applicationStates = EnumSet.noneOf(YarnApplicationState.class);

  for (YarnApplicationStateProto c : appStatesList) {
    this.applicationStates.add(ProtoUtils.convertFromProtoFormat(c));
  }
}

项目：aliyun-oss-hadoop-fs 文件：GetApplicationsRequestPBImpl.java

private void initApplicationStates() {
  if (this.applicationStates != null) {
    return;
  }
  GetApplicationsRequestProtoOrBuilder p = viaProto ? proto : builder;
  List<YarnApplicationStateProto> appStatesList =
      p.getApplicationStatesList();
  this.applicationStates = EnumSet.noneOf(YarnApplicationState.class);

  for (YarnApplicationStateProto c : appStatesList) {
    this.applicationStates.add(ProtoUtils.convertFromProtoFormat(c));
  }
}

项目：big-c 文件：GetApplicationsRequestPBImpl.java

private void initApplicationStates() {
  if (this.applicationStates != null) {
    return;
  }
  GetApplicationsRequestProtoOrBuilder p = viaProto ? proto : builder;
  List<YarnApplicationStateProto> appStatesList =
      p.getApplicationStatesList();
  this.applicationStates = EnumSet.noneOf(YarnApplicationState.class);

  for (YarnApplicationStateProto c : appStatesList) {
    this.applicationStates.add(ProtoUtils.convertFromProtoFormat(c));
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：GetApplicationsRequestPBImpl.java

private void initApplicationStates() {
  if (this.applicationStates != null) {
    return;
  }
  GetApplicationsRequestProtoOrBuilder p = viaProto ? proto : builder;
  List<YarnApplicationStateProto> appStatesList =
      p.getApplicationStatesList();
  this.applicationStates = EnumSet.noneOf(YarnApplicationState.class);

  for (YarnApplicationStateProto c : appStatesList) {
    this.applicationStates.add(ProtoUtils.convertFromProtoFormat(c));
  }
}

项目：hops 文件：GetApplicationsRequestPBImpl.java

private void initApplicationStates() {
  if (this.applicationStates != null) {
    return;
  }
  GetApplicationsRequestProtoOrBuilder p = viaProto ? proto : builder;
  List<YarnApplicationStateProto> appStatesList =
      p.getApplicationStatesList();
  this.applicationStates = EnumSet.noneOf(YarnApplicationState.class);

  for (YarnApplicationStateProto c : appStatesList) {
    this.applicationStates.add(ProtoUtils.convertFromProtoFormat(c));
  }
}

项目：hadoop-TCP 文件：GetApplicationsRequestPBImpl.java

private void mergeLocalToBuilder() {
  if (this.applicationTypes != null) {
    addLocalApplicationTypestoProto();
  }
  if (this.applicationStates != null) {
    maybeInitBuilder();
    builder.clearapplicationStates();
    Iterable<YarnApplicationStateProto> iterable =
        new Iterable<YarnApplicationStateProto>() {

          @Override
          public Iterator<YarnApplicationStateProto> iterator() {
            return new Iterator<YarnApplicationStateProto>() {

              Iterator<YarnApplicationState> iter = applicationStates
                  .iterator();

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

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

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

              }
            };

          }
        };
    builder.addAllApplicationStates(iterable);
  }
}

项目：hadoop-TCP 文件：GetApplicationsRequestPBImpl.java

private void initApplicationStates() {
  if (this.applicationStates != null) {
    return;
  }
  GetApplicationsRequestProtoOrBuilder p = viaProto ? proto : builder;
  List<YarnApplicationStateProto> appStatesList =
      p.getApplicationStatesList();
  this.applicationStates = EnumSet.noneOf(YarnApplicationState.class);

  for (YarnApplicationStateProto c : appStatesList) {
    this.applicationStates.add(ProtoUtils.convertFromProtoFormat(c));
  }
}

项目：hardfs 文件：GetApplicationsRequestPBImpl.java

private void mergeLocalToBuilder() {
  if (this.applicationTypes != null) {
    addLocalApplicationTypestoProto();
  }
  if (this.applicationStates != null) {
    maybeInitBuilder();
    builder.clearapplicationStates();
    Iterable<YarnApplicationStateProto> iterable =
        new Iterable<YarnApplicationStateProto>() {

          @Override
          public Iterator<YarnApplicationStateProto> iterator() {
            return new Iterator<YarnApplicationStateProto>() {

              Iterator<YarnApplicationState> iter = applicationStates
                  .iterator();

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

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

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

              }
            };

          }
        };
    builder.addAllApplicationStates(iterable);
  }
}

项目：hardfs 文件：GetApplicationsRequestPBImpl.java

private void initApplicationStates() {
  if (this.applicationStates != null) {
    return;
  }
  GetApplicationsRequestProtoOrBuilder p = viaProto ? proto : builder;
  List<YarnApplicationStateProto> appStatesList =
      p.getApplicationStatesList();
  this.applicationStates = EnumSet.noneOf(YarnApplicationState.class);

  for (YarnApplicationStateProto c : appStatesList) {
    this.applicationStates.add(ProtoUtils.convertFromProtoFormat(c));
  }
}

项目：hadoop-on-lustre2 文件：GetApplicationsRequestPBImpl.java

private void initApplicationStates() {
  if (this.applicationStates != null) {
    return;
  }
  GetApplicationsRequestProtoOrBuilder p = viaProto ? proto : builder;
  List<YarnApplicationStateProto> appStatesList =
      p.getApplicationStatesList();
  this.applicationStates = EnumSet.noneOf(YarnApplicationState.class);

  for (YarnApplicationStateProto c : appStatesList) {
    this.applicationStates.add(ProtoUtils.convertFromProtoFormat(c));
  }
}

项目：hadoop 文件：GetApplicationsRequestPBImpl.java

private void mergeLocalToBuilder() {
  if (applicationTypes != null && !applicationTypes.isEmpty()) {
    builder.clearapplicationTypes();
    builder.addAllApplicationTypes(applicationTypes);
  }
  if (applicationStates != null && !applicationStates.isEmpty()) {
    builder.clearapplicationStates();
    builder.addAllApplicationStates(Iterables.transform(applicationStates,new Function<YarnApplicationState,YarnApplicationStateProto>() {
          @Override
          public YarnApplicationStateProto apply(YarnApplicationState input) {
            return ProtoUtils.convertToProtoFormat(input);
          }
        }));
  }
  if (applicationTags != null && !applicationTags.isEmpty()) {
    builder.clearapplicationTags();
    builder.addAllApplicationTags(this.applicationTags);
  }
  if (scope != null) {
    builder.setScope(ProtoUtils.convertToProtoFormat(scope));
  }
  if (start != null) {
    builder.setStartBegin(start.getMinimumLong());
    builder.setStartEnd(start.getMaximumLong());
  }
  if (finish != null) {
    builder.setFinishBegin(finish.getMinimumLong());
    builder.setFinishEnd(finish.getMaximumLong());
  }
  if (limit != Long.MAX_VALUE) {
    builder.setLimit(limit);
  }
  if (users != null && !users.isEmpty()) {
    builder.clearUsers();
    builder.addAllUsers(users);
  }
  if (queues != null && !queues.isEmpty()) {
    builder.clearQueues();
    builder.addAllQueues(queues);
  }
}

项目：hadoop 文件：ProtoUtils.java

public static YarnApplicationStateProto convertToProtoFormat(YarnApplicationState e) {
  return YarnApplicationStateProto.valueOf(e.name());
}

项目：hadoop 文件：ProtoUtils.java

public static YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto e) {
  return YarnApplicationState.valueOf(e.name());
}

项目：hadoop 文件：ApplicationReportPBImpl.java

private YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto s) {
  return ProtoUtils.convertFromProtoFormat(s);
}

项目：hadoop 文件：ApplicationReportPBImpl.java

private YarnApplicationStateProto convertToProtoFormat(YarnApplicationState s) {
  return ProtoUtils.convertToProtoFormat(s);
}

项目：hadoop 文件：ApplicationFinishDataPBImpl.java

private YarnApplicationStateProto convertToProtoFormat(
    YarnApplicationState state) {
  return ProtoUtils.convertToProtoFormat(state);
}

项目：hadoop 文件：ApplicationFinishDataPBImpl.java

private YarnApplicationState convertFromProtoFormat(
    YarnApplicationStateProto yarnApplicationState) {
  return ProtoUtils.convertFromProtoFormat(yarnApplicationState);
}

项目：aliyun-oss-hadoop-fs 文件：GetApplicationsRequestPBImpl.java

private void mergeLocalToBuilder() {
  if (applicationTypes != null && !applicationTypes.isEmpty()) {
    builder.clearapplicationTypes();
    builder.addAllApplicationTypes(applicationTypes);
  }
  if (applicationStates != null && !applicationStates.isEmpty()) {
    builder.clearapplicationStates();
    builder.addAllApplicationStates(Iterables.transform(applicationStates,YarnApplicationStateProto>() {
          @Override
          public YarnApplicationStateProto apply(YarnApplicationState input) {
            return ProtoUtils.convertToProtoFormat(input);
          }
        }));
  }
  if (applicationTags != null && !applicationTags.isEmpty()) {
    builder.clearapplicationTags();
    builder.addAllApplicationTags(this.applicationTags);
  }
  if (scope != null) {
    builder.setScope(ProtoUtils.convertToProtoFormat(scope));
  }
  if (start != null) {
    builder.setStartBegin(start.getMinimumLong());
    builder.setStartEnd(start.getMaximumLong());
  }
  if (finish != null) {
    builder.setFinishBegin(finish.getMinimumLong());
    builder.setFinishEnd(finish.getMaximumLong());
  }
  if (limit != Long.MAX_VALUE) {
    builder.setLimit(limit);
  }
  if (users != null && !users.isEmpty()) {
    builder.clearUsers();
    builder.addAllUsers(users);
  }
  if (queues != null && !queues.isEmpty()) {
    builder.clearQueues();
    builder.addAllQueues(queues);
  }
}

项目：aliyun-oss-hadoop-fs 文件：ProtoUtils.java

public static YarnApplicationStateProto convertToProtoFormat(YarnApplicationState e) {
  return YarnApplicationStateProto.valueOf(e.name());
}

项目：aliyun-oss-hadoop-fs 文件：ProtoUtils.java

public static YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto e) {
  return YarnApplicationState.valueOf(e.name());
}

项目：aliyun-oss-hadoop-fs 文件：ApplicationReportPBImpl.java

private YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto s) {
  return ProtoUtils.convertFromProtoFormat(s);
}

项目：aliyun-oss-hadoop-fs 文件：ApplicationReportPBImpl.java

private YarnApplicationStateProto convertToProtoFormat(YarnApplicationState s) {
  return ProtoUtils.convertToProtoFormat(s);
}

项目：aliyun-oss-hadoop-fs 文件：ApplicationFinishDataPBImpl.java

private YarnApplicationStateProto convertToProtoFormat(
    YarnApplicationState state) {
  return ProtoUtils.convertToProtoFormat(state);
}

项目：aliyun-oss-hadoop-fs 文件：ApplicationFinishDataPBImpl.java

private YarnApplicationState convertFromProtoFormat(
    YarnApplicationStateProto yarnApplicationState) {
  return ProtoUtils.convertFromProtoFormat(yarnApplicationState);
}

项目：big-c 文件：GetApplicationsRequestPBImpl.java

private void mergeLocalToBuilder() {
  if (applicationTypes != null && !applicationTypes.isEmpty()) {
    builder.clearapplicationTypes();
    builder.addAllApplicationTypes(applicationTypes);
  }
  if (applicationStates != null && !applicationStates.isEmpty()) {
    builder.clearapplicationStates();
    builder.addAllApplicationStates(Iterables.transform(applicationStates,YarnApplicationStateProto>() {
          @Override
          public YarnApplicationStateProto apply(YarnApplicationState input) {
            return ProtoUtils.convertToProtoFormat(input);
          }
        }));
  }
  if (applicationTags != null && !applicationTags.isEmpty()) {
    builder.clearapplicationTags();
    builder.addAllApplicationTags(this.applicationTags);
  }
  if (scope != null) {
    builder.setScope(ProtoUtils.convertToProtoFormat(scope));
  }
  if (start != null) {
    builder.setStartBegin(start.getMinimumLong());
    builder.setStartEnd(start.getMaximumLong());
  }
  if (finish != null) {
    builder.setFinishBegin(finish.getMinimumLong());
    builder.setFinishEnd(finish.getMaximumLong());
  }
  if (limit != Long.MAX_VALUE) {
    builder.setLimit(limit);
  }
  if (users != null && !users.isEmpty()) {
    builder.clearUsers();
    builder.addAllUsers(users);
  }
  if (queues != null && !queues.isEmpty()) {
    builder.clearQueues();
    builder.addAllQueues(queues);
  }
}

项目：big-c 文件：ProtoUtils.java

public static YarnApplicationStateProto convertToProtoFormat(YarnApplicationState e) {
  return YarnApplicationStateProto.valueOf(e.name());
}

项目：big-c 文件：ProtoUtils.java

public static YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto e) {
  return YarnApplicationState.valueOf(e.name());
}

项目：big-c 文件：ApplicationReportPBImpl.java

private YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto s) {
  return ProtoUtils.convertFromProtoFormat(s);
}

项目：big-c 文件：ApplicationReportPBImpl.java

private YarnApplicationStateProto convertToProtoFormat(YarnApplicationState s) {
  return ProtoUtils.convertToProtoFormat(s);
}

项目：big-c 文件：ApplicationFinishDataPBImpl.java

private YarnApplicationStateProto convertToProtoFormat(
    YarnApplicationState state) {
  return ProtoUtils.convertToProtoFormat(state);
}

项目：big-c 文件：ApplicationFinishDataPBImpl.java

private YarnApplicationState convertFromProtoFormat(
    YarnApplicationStateProto yarnApplicationState) {
  return ProtoUtils.convertFromProtoFormat(yarnApplicationState);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：GetApplicationsRequestPBImpl.java

private void mergeLocalToBuilder() {
  if (applicationTypes != null && !applicationTypes.isEmpty()) {
    builder.clearapplicationTypes();
    builder.addAllApplicationTypes(applicationTypes);
  }
  if (applicationStates != null && !applicationStates.isEmpty()) {
    builder.clearapplicationStates();
    builder.addAllApplicationStates(Iterables.transform(applicationStates,YarnApplicationStateProto>() {
          @Override
          public YarnApplicationStateProto apply(YarnApplicationState input) {
            return ProtoUtils.convertToProtoFormat(input);
          }
        }));
  }
  if (applicationTags != null && !applicationTags.isEmpty()) {
    builder.clearapplicationTags();
    builder.addAllApplicationTags(this.applicationTags);
  }
  if (scope != null) {
    builder.setScope(ProtoUtils.convertToProtoFormat(scope));
  }
  if (start != null) {
    builder.setStartBegin(start.getMinimumLong());
    builder.setStartEnd(start.getMaximumLong());
  }
  if (finish != null) {
    builder.setFinishBegin(finish.getMinimumLong());
    builder.setFinishEnd(finish.getMaximumLong());
  }
  if (limit != Long.MAX_VALUE) {
    builder.setLimit(limit);
  }
  if (users != null && !users.isEmpty()) {
    builder.clearUsers();
    builder.addAllUsers(users);
  }
  if (queues != null && !queues.isEmpty()) {
    builder.clearQueues();
    builder.addAllQueues(queues);
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ProtoUtils.java

public static YarnApplicationStateProto convertToProtoFormat(YarnApplicationState e) {
  return YarnApplicationStateProto.valueOf(e.name());
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ProtoUtils.java

public static YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto e) {
  return YarnApplicationState.valueOf(e.name());
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ApplicationReportPBImpl.java

private YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto s) {
  return ProtoUtils.convertFromProtoFormat(s);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ApplicationReportPBImpl.java

private YarnApplicationStateProto convertToProtoFormat(YarnApplicationState s) {
  return ProtoUtils.convertToProtoFormat(s);
}

项目：hadoop-plus 文件：ProtoUtils.java

public static YarnApplicationStateProto convertToProtoFormat(YarnApplicationState e) {
  return YarnApplicationStateProto.valueOf(e.name());
}

项目：hadoop-plus 文件：ProtoUtils.java

public static YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto e) {
  return YarnApplicationState.valueOf(e.name());
}

项目：hadoop-plus 文件：ApplicationReportPBImpl.java

private YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto s) {
  return ProtoUtils.convertFromProtoFormat(s);
}

项目：hadoop-plus 文件：ApplicationReportPBImpl.java

private YarnApplicationStateProto convertToProtoFormat(YarnApplicationState s) {
  return ProtoUtils.convertToProtoFormat(s);
}

org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProto的实例源码

项目：hadoop 文件：ApplicationMasterProtocolPBClientImpl.java

@Override
public AllocateResponse allocate(AllocateRequest request)
    throws YarnException,IOException {
  AllocateRequestProto requestProto =
      ((AllocateRequestPBImpl) request).getProto();
  try {
    return new AllocateResponsePBImpl(proxy.allocate(null,requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：aliyun-oss-hadoop-fs 文件：ApplicationMasterProtocolPBClientImpl.java

@Override
public AllocateResponse allocate(AllocateRequest request)
    throws YarnException,requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：big-c 文件：ApplicationMasterProtocolPBClientImpl.java

@Override
public AllocateResponse allocate(AllocateRequest request)
    throws YarnException,requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ApplicationMasterProtocolPBClientImpl.java

@Override
public AllocateResponse allocate(AllocateRequest request)
    throws YarnException,requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop-plus 文件：ApplicationMasterProtocolPBClientImpl.java

@Override
public AllocateResponse allocate(AllocateRequest request)
    throws YarnException,requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hops 文件：ApplicationMasterProtocolPBClientImpl.java

@Override
public AllocateResponse allocate(AllocateRequest request)
    throws YarnException,requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop-TCP 文件：ApplicationMasterProtocolPBClientImpl.java

@Override
public AllocateResponse allocate(AllocateRequest request)
    throws YarnException,requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hardfs 文件：ApplicationMasterProtocolPBClientImpl.java

@Override
public AllocateResponse allocate(AllocateRequest request)
    throws YarnException,requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop-on-lustre2 文件：ApplicationMasterProtocolPBClientImpl.java

@Override
public AllocateResponse allocate(AllocateRequest request)
    throws YarnException,requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}

项目：hadoop 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl() {
  builder = AllocateRequestProto.newBuilder();
}

项目：hadoop 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl(AllocateRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop 文件：AllocateRequestPBImpl.java

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

项目：hadoop 文件：AllocateRequestPBImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl() {
  builder = AllocateRequestProto.newBuilder();
}

项目：aliyun-oss-hadoop-fs 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl(AllocateRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：aliyun-oss-hadoop-fs 文件：AllocateRequestPBImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：AllocateRequestPBImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：TestPBImplRecords.java

@Test
public void testAllocateRequestPBImpl() throws Exception {
  validatePBImplRecord(AllocateRequestPBImpl.class,AllocateRequestProto.class);
}

项目：big-c 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl() {
  builder = AllocateRequestProto.newBuilder();
}

项目：big-c 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl(AllocateRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：big-c 文件：AllocateRequestPBImpl.java

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

项目：big-c 文件：AllocateRequestPBImpl.java

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

项目：hadoop-2.6.0-cdh5.4.3 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl() {
  builder = AllocateRequestProto.newBuilder();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl(AllocateRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：AllocateRequestPBImpl.java

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

项目：hadoop-2.6.0-cdh5.4.3 文件：AllocateRequestPBImpl.java

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

项目：hadoop-plus 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl() {
  builder = AllocateRequestProto.newBuilder();
}

项目：hadoop-plus 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl(AllocateRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-plus 文件：AllocateRequestPBImpl.java

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

项目：hadoop-plus 文件：AllocateRequestPBImpl.java

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

项目：hops 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl() {
  builder = AllocateRequestProto.newBuilder();
}

项目：hops 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl(AllocateRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hops 文件：AllocateRequestPBImpl.java

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

项目：hops 文件：AllocateRequestPBImpl.java

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

项目：hops 文件：TestPBImplRecords.java

@Test
public void testAllocateRequestPBImpl() throws Exception {
  validatePBImplRecord(AllocateRequestPBImpl.class,AllocateRequestProto.class);
}

项目：hadoop-TCP 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl() {
  builder = AllocateRequestProto.newBuilder();
}

项目：hadoop-TCP 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl(AllocateRequestProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-TCP 文件：AllocateRequestPBImpl.java

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

项目：hadoop-TCP 文件：AllocateRequestPBImpl.java

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

项目：hardfs 文件：AllocateRequestPBImpl.java

public AllocateRequestPBImpl() {
  builder = AllocateRequestProto.newBuilder();
}

org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto的实例源码

项目：hadoop 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl() {
  builder = AllocateResponseProto.newBuilder();
}

项目：hadoop 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl(AllocateResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop 文件：AllocateResponsePBImpl.java

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

项目：hadoop 文件：AllocateResponsePBImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl() {
  builder = AllocateResponseProto.newBuilder();
}

项目：aliyun-oss-hadoop-fs 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl(AllocateResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：aliyun-oss-hadoop-fs 文件：AllocateResponsePBImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：AllocateResponsePBImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：TestPBImplRecords.java

@Test
public void testAllocateResponsePBImpl() throws Exception {
  validatePBImplRecord(AllocateResponsePBImpl.class,AllocateResponseProto.class);
}

项目：big-c 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl() {
  builder = AllocateResponseProto.newBuilder();
}

项目：big-c 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl(AllocateResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：big-c 文件：AllocateResponsePBImpl.java

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

项目：big-c 文件：AllocateResponsePBImpl.java

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

项目：hadoop-2.6.0-cdh5.4.3 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl() {
  builder = AllocateResponseProto.newBuilder();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl(AllocateResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：AllocateResponsePBImpl.java

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

项目：hadoop-2.6.0-cdh5.4.3 文件：AllocateResponsePBImpl.java

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

项目：hadoop-plus 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl() {
  builder = AllocateResponseProto.newBuilder();
}

项目：hadoop-plus 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl(AllocateResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-plus 文件：AllocateResponsePBImpl.java

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

项目：hadoop-plus 文件：AllocateResponsePBImpl.java

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

项目：hops 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl() {
  builder = AllocateResponseProto.newBuilder();
}

项目：hops 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl(AllocateResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hops 文件：AllocateResponsePBImpl.java

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

项目：hops 文件：AllocateResponsePBImpl.java

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

项目：hops 文件：TestPBImplRecords.java

@Test
public void testAllocateResponsePBImpl() throws Exception {
  validatePBImplRecord(AllocateResponsePBImpl.class,AllocateResponseProto.class);
}

项目：hadoop-TCP 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl() {
  builder = AllocateResponseProto.newBuilder();
}

项目：hadoop-TCP 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl(AllocateResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-TCP 文件：AllocateResponsePBImpl.java

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

项目：hadoop-TCP 文件：AllocateResponsePBImpl.java

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

项目：hardfs 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl() {
  builder = AllocateResponseProto.newBuilder();
}

项目：hardfs 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl(AllocateResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hardfs 文件：AllocateResponsePBImpl.java

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

项目：hardfs 文件：AllocateResponsePBImpl.java

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

项目：hadoop-on-lustre2 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl() {
  builder = AllocateResponseProto.newBuilder();
}

项目：hadoop-on-lustre2 文件：AllocateResponsePBImpl.java

public AllocateResponsePBImpl(AllocateResponseProto proto) {
  this.proto = proto;
  viaProto = true;
}

项目：hadoop-on-lustre2 文件：AllocateResponsePBImpl.java

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

项目：hadoop-on-lustre2 文件：AllocateResponsePBImpl.java

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

我们今天的关于org.apache.hadoop.yarn.proto.YarnServiceProtos.MoveApplicationAcrossQueuesResponseProto的实例源码的分享已经告一段落，感谢您的关注，如果您想了解更多关于org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAccessTypeProto的实例源码、org.apache.hadoop.yarn.proto.YarnProtos.YarnApplicationStateProto的实例源码、org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProto的实例源码、org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto的实例源码的相关信息，请在本站查询。

本文标签：