gpt4 book ai didi

org.apache.phoenix.mapreduce.index.automation.YarnApplication.getName()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-20 18:46:31 25 4
gpt4 key购买 nike

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

YarnApplication.getName介绍

暂无

代码示例

代码示例来源: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;
}

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com