本文整理了Java中org.apache.spark.SparkContext.uiWebUrl()
方法的一些代码示例,展示了SparkContext.uiWebUrl()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。SparkContext.uiWebUrl()
方法的具体详情如下:
包路径:org.apache.spark.SparkContext
类名称: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";
}
}
内容来源于网络,如有侵权,请联系作者删除!