源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.hadoop.yarn.proto.YarnProtos.YarnApplicationStateProto

示例1
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));
  }
}
示例2
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));
  }
}
示例3
private YarnApplicationStateProto convertToProtoFormat(
    YarnApplicationState state) {
  return ProtoUtils.convertToProtoFormat(state);
}
示例4
private YarnApplicationState convertFromProtoFormat(
    YarnApplicationStateProto yarnApplicationState) {
  return ProtoUtils.convertFromProtoFormat(yarnApplicationState);
}
示例5
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);
  }
}
示例6
public static YarnApplicationStateProto convertToProtoFormat(YarnApplicationState e) {
  return YarnApplicationStateProto.valueOf(e.name());
}
示例7
public static YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto e) {
  return YarnApplicationState.valueOf(e.name());
}
示例8
private YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto s) {
  return ProtoUtils.convertFromProtoFormat(s);
}
示例9
private YarnApplicationStateProto convertToProtoFormat(YarnApplicationState s) {
  return ProtoUtils.convertToProtoFormat(s);
}
示例10
private YarnApplicationStateProto convertToProtoFormat(
    YarnApplicationState state) {
  return ProtoUtils.convertToProtoFormat(state);
}
示例11
private YarnApplicationState convertFromProtoFormat(
    YarnApplicationStateProto yarnApplicationState) {
  return ProtoUtils.convertFromProtoFormat(yarnApplicationState);
}
示例12
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);
  }
}
示例13
public static YarnApplicationStateProto convertToProtoFormat(YarnApplicationState e) {
  return YarnApplicationStateProto.valueOf(e.name());
}
示例14
public static YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto e) {
  return YarnApplicationState.valueOf(e.name());
}
示例15
private YarnApplicationState convertFromProtoFormat(YarnApplicationStateProto s) {
  return ProtoUtils.convertFromProtoFormat(s);
}
示例16
private YarnApplicationStateProto convertToProtoFormat(YarnApplicationState s) {
  return ProtoUtils.convertToProtoFormat(s);
}
示例17
private YarnApplicationStateProto convertToProtoFormat(
    YarnApplicationState state) {
  return ProtoUtils.convertToProtoFormat(state);
}
示例18
private YarnApplicationState convertFromProtoFormat(
    YarnApplicationStateProto yarnApplicationState) {
  return ProtoUtils.convertFromProtoFormat(yarnApplicationState);
}