org.apache.spark.SparkContext.uiWebUrl()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(1.5k)|赞(0)|评价(0)|浏览(114)

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

SparkContext.uiWebUrl介绍

暂无

代码示例

代码示例来源:origin: apache/hive

@Override
public String getWebUIURL() {
 try {
  if (sparkContext.sc().uiWebUrl().isDefined()) {
   return SparkUtilities.reverseDNSLookupURL(sparkContext.sc().uiWebUrl().get());
  } else {
   return "UNDEFINED";
  }
 } catch (Exception e) {
  LOG.warn("Failed to get web UI URL.", e);
 }
 return "UNKNOWN";
}

代码示例来源:origin: twosigma/beakerx

@Override
public String getSparkUiWebUrl() {
 return getOrCreate().sparkContext().uiWebUrl().get();
}

代码示例来源:origin: twosigma/beakerx

private String stageLink(int stageId) {
 if (getSparkSession().sparkContext().uiWebUrl().isDefined()) {
  return getSparkSession().sparkContext().uiWebUrl().get() + "/stages/stage/?id=" + stageId + "&attempt=0";
 } else {
  return "";
 }
}

代码示例来源:origin: twosigma/beakerx

private String jobLink(int jobId) {
 if (getSparkSession().sparkContext().uiWebUrl().isDefined()) {
  return getSparkSession().sparkContext().uiWebUrl().get() + "/jobs/job/?id=" + jobId;
 } else {
  return "";
 }
}

代码示例来源:origin: apache/hive

@Override
 public String call(JobContext jc) throws Exception {
  if (jc.sc().sc().uiWebUrl().isDefined()) {
   return SparkUtilities.reverseDNSLookupURL(jc.sc().sc().uiWebUrl().get());
  }
  return "UNDEFINED";
 }
}

相关文章