org.apache.hadoop.yarn.webapp.WebApp.httpServer()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(4.8k)|赞(0)|评价(0)|浏览(319)

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

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.";

相关文章