本文整理了Java中org.apache.hadoop.yarn.webapp.WebApp.httpServer()
方法的一些代码示例,展示了WebApp.httpServer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WebApp.httpServer()
方法的具体详情如下:
包路径:org.apache.hadoop.yarn.webapp.WebApp
类名称:WebApp
方法名:httpServer
暂无
代码示例来源:origin: Qihoo360/XLearning
Method webAppBuild = WebApps.Builder.class.getMethod("build", WebApp.class);
webApp = (WebApp) webAppBuild.invoke(WebApps.$for("proxy", ApplicationContext.class, applicationContext, null).with(getConfig()), new AMWebApp());
HttpServer2 httpServer = webApp.httpServer();
代码示例来源:origin: Qihoo360/XLearning
Method webAppBuild = WebApps.Builder.class.getMethod("build", WebApp.class);
webAppBuild.invoke(WebApps.$for("jobhistory", HistoryClientService.class, this, "ws").with(conf).withHttpSpnegoKeytabKey(XLearningConfiguration.XLEARNING_WEBAPP_SPNEGO_KEYTAB_FILE_KEY).withHttpSpnegoPrincipalKey(XLearningConfiguration.XLEARNING_WEBAPP_SPNEGO_USER_NAME_KEY).at(NetUtils.getHostPortString(bindAddress)), webApp);
HttpServer2 httpServer = webApp.httpServer();
WebAppContext webAppContext = httpServer.getWebAppContext();
WebAppContext appWebAppContext = new WebAppContext();
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-applicationhistoryservice
private InetSocketAddress getListenerAddress() {
return this.webApp.httpServer().getConnectorAddress(0);
}
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-server-applicationhistoryservice
private InetSocketAddress getListenerAddress() {
return this.webApp.httpServer().getConnectorAddress(0);
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice
private InetSocketAddress getListenerAddress() {
return this.webApp.httpServer().getConnectorAddress(0);
}
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-common
public WebApp start(WebApp webapp) {
WebApp webApp = build(webapp);
HttpServer2 httpServer = webApp.httpServer();
try {
httpServer.start();
LOG.info("Web app " + name + " started at "
+ httpServer.getConnectorAddress(0).getPort());
} catch (IOException e) {
throw new WebAppException("Error starting http server", e);
}
return webApp;
}
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-common
public WebApp start(WebApp webapp) {
WebApp webApp = build(webapp);
HttpServer2 httpServer = webApp.httpServer();
try {
httpServer.start();
LOG.info("Web app " + name + " started at "
+ httpServer.getConnectorAddress(0).getPort());
} catch (IOException e) {
throw new WebAppException("Error starting http server", e);
}
return webApp;
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-common
public WebApp start(WebApp webapp, WebAppContext ui2Context) {
WebApp webApp = build(webapp);
HttpServer2 httpServer = webApp.httpServer();
if (ui2Context != null) {
addFiltersForNewContext(ui2Context);
httpServer.addHandlerAtFront(ui2Context);
}
try {
httpServer.start();
LOG.info("Web app " + name + " started at "
+ httpServer.getConnectorAddress(0).getPort());
} catch (IOException e) {
throw new WebAppException("Error starting http server", e);
}
return webApp;
}
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-nodemanager
.withXFSProtection(YarnConfiguration.NM_XFS_PREFIX)
.start(this.nmWebApp);
this.port = this.webApp.httpServer().getConnectorAddress(0).getPort();
} catch (Exception e) {
String msg = "NMWebapps failed to start.";
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-server-applicationhistoryservice
.with(conf).withAttribute(YarnConfiguration.TIMELINE_SERVICE_WEBAPP_ADDRESS,
conf.get(YarnConfiguration.TIMELINE_SERVICE_WEBAPP_ADDRESS)).at(bindAddress).build(ahsWebApp);
HttpServer2 httpServer = webApp.httpServer();
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-applicationhistoryservice
.with(conf).withAttribute(YarnConfiguration.TIMELINE_SERVICE_WEBAPP_ADDRESS,
conf.get(YarnConfiguration.TIMELINE_SERVICE_WEBAPP_ADDRESS)).at(bindAddress).build(ahsWebApp);
HttpServer2 httpServer = webApp.httpServer();
代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice
.withXFSProtection(YarnConfiguration.TIMELINE_XFS_PREFIX)
.at(bindAddress).build(ahsWebApp);
HttpServer2 httpServer = webApp.httpServer();
代码示例来源:origin: io.hops/hadoop-yarn-server-nodemanager
YarnConfiguration.NM_WEBAPP_SPNEGO_KEYTAB_FILE_KEY)
.start(this.nmWebApp);
this.port = this.webApp.httpServer().getConnectorAddress(0).getPort();
} catch (Exception e) {
String msg = "NMWebapps failed to start.";
代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-nodemanager
YarnConfiguration.NM_WEBAPP_SPNEGO_KEYTAB_FILE_KEY)
.start(this.nmWebApp);
this.port = this.webApp.httpServer().getConnectorAddress(0).getPort();
} catch (Exception e) {
String msg = "NMWebapps failed to start.";
代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-server-nodemanager
YarnConfiguration.NM_WEBAPP_SPNEGO_KEYTAB_FILE_KEY)
.start(this.nmWebApp);
this.port = this.webApp.httpServer().getConnectorAddress(0).getPort();
} catch (Exception e) {
String msg = "NMWebapps failed to start.";
内容来源于网络,如有侵权,请联系作者删除!