本文整理了Java中org.apache.phoenix.mapreduce.index.automation.YarnApplication类的一些代码示例，展示了YarnApplication类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YarnApplication类的具体详情如下：
包路径：org.apache.phoenix.mapreduce.index.automation.YarnApplication
类名称：YarnApplication

YarnApplication介绍

暂无

代码示例

代码示例来源：origin: apache/phoenix

public Set<String> getSubmittedYarnApps() throws Exception {
  String rmHost = PhoenixMRJobUtil.getActiveResourceManagerHost(conf, zkQuorum);
  Map<String, String> urlParams = new HashMap<String, String>();
  urlParams.put(YarnApplication.APP_STATES_ELEMENT, YarnApplication.state.NEW.toString()
      + "," + YarnApplication.state.ACCEPTED + "," + YarnApplication.state.SUBMITTED
      + "," + YarnApplication.state.RUNNING);
  int rmPort = PhoenixMRJobUtil.getRMPort(conf);
  String response = PhoenixMRJobUtil.getJobsInformationFromRM(rmHost, rmPort, urlParams);
  LOG.debug("Already Submitted/Running Apps = " + response);
  JSONObject jobsJson = new JSONObject(response);
  JSONObject appsJson = jobsJson.optJSONObject(YarnApplication.APPS_ELEMENT);
  Set<String> yarnApplicationSet = new HashSet<String>();
  if (appsJson == null) {
    return yarnApplicationSet;
  }
  JSONArray appJson = appsJson.optJSONArray(YarnApplication.APP_ELEMENT);
  if (appJson == null) {
    return yarnApplicationSet;
  }
  for (int i = 0; i < appJson.length(); i++) {
    Gson gson = new GsonBuilder().create();
    YarnApplication yarnApplication =
        gson.fromJson(appJson.getJSONObject(i).toString(),
          new TypeToken<YarnApplication>() {
          }.getType());
    yarnApplicationSet.add(yarnApplication.getName());
  }
  return yarnApplicationSet;
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

public Set<String> getSubmittedYarnApps() throws Exception {
  String rmHost = PhoenixMRJobUtil.getActiveResourceManagerHost(conf, zkQuorum);
  Map<String, String> urlParams = new HashMap<String, String>();
  urlParams.put(YarnApplication.APP_STATES_ELEMENT, YarnApplication.state.NEW.toString()
      + "," + YarnApplication.state.ACCEPTED + "," + YarnApplication.state.SUBMITTED
      + "," + YarnApplication.state.RUNNING);
  int rmPort = PhoenixMRJobUtil.getRMPort(conf);
  String response = PhoenixMRJobUtil.getJobsInformationFromRM(rmHost, rmPort, urlParams);
  LOG.debug("Already Submitted/Running Apps = " + response);
  JSONObject jobsJson = new JSONObject(response);
  JSONObject appsJson = jobsJson.optJSONObject(YarnApplication.APPS_ELEMENT);
  Set<String> yarnApplicationSet = new HashSet<String>();
  if (appsJson == null) {
    return yarnApplicationSet;
  }
  JSONArray appJson = appsJson.optJSONArray(YarnApplication.APP_ELEMENT);
  if (appJson == null) {
    return yarnApplicationSet;
  }
  for (int i = 0; i < appJson.length(); i++) {
    Gson gson = new GsonBuilder().create();
    YarnApplication yarnApplication =
        gson.fromJson(appJson.getJSONObject(i).toString(),
          new TypeToken<YarnApplication>() {
          }.getType());
    yarnApplicationSet.add(yarnApplication.getName());
  }
  return yarnApplicationSet;
}

代码示例来源：origin: org.apache.phoenix/phoenix-core

public Set<String> getSubmittedYarnApps() throws Exception {
  String rmHost = PhoenixMRJobUtil.getActiveResourceManagerHost(conf, zkQuorum);
  Map<String, String> urlParams = new HashMap<String, String>();
  urlParams.put(YarnApplication.APP_STATES_ELEMENT, YarnApplication.state.NEW.toString()
      + "," + YarnApplication.state.ACCEPTED + "," + YarnApplication.state.SUBMITTED
      + "," + YarnApplication.state.RUNNING);
  int rmPort = PhoenixMRJobUtil.getRMPort(conf);
  String response = PhoenixMRJobUtil.getJobsInformationFromRM(rmHost, rmPort, urlParams);
  LOG.debug("Already Submitted/Running Apps = " + response);
  JSONObject jobsJson = new JSONObject(response);
  JSONObject appsJson = jobsJson.optJSONObject(YarnApplication.APPS_ELEMENT);
  Set<String> yarnApplicationSet = new HashSet<String>();
  if (appsJson == null) {
    return yarnApplicationSet;
  }
  JSONArray appJson = appsJson.optJSONArray(YarnApplication.APP_ELEMENT);
  if (appJson == null) {
    return yarnApplicationSet;
  }
  for (int i = 0; i < appJson.length(); i++) {
    Gson gson = new GsonBuilder().create();
    YarnApplication yarnApplication =
        gson.fromJson(appJson.getJSONObject(i).toString(),
          new TypeToken<YarnApplication>() {
          }.getType());
    yarnApplicationSet.add(yarnApplication.getName());
  }
  return yarnApplicationSet;
}