• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

Java ProxyUriUtils类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils类的典型用法代码示例。如果您正苦于以下问题：Java ProxyUriUtils类的具体用法？Java ProxyUriUtils怎么用？Java ProxyUriUtils使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



ProxyUriUtils类属于org.apache.hadoop.yarn.server.webproxy包，在下文中一共展示了ProxyUriUtils类的12个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: generateProxyUriWithScheme

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
private String generateProxyUriWithScheme() {
  this.readLock.lock();
  try {
    final String scheme = WebAppUtils.getHttpSchemePrefix(conf);
    String proxy = WebAppUtils.getProxyHostAndPort(conf);
    URI proxyUri = ProxyUriUtils.getUriFromAMUrl(scheme, proxy);
    URI result = ProxyUriUtils.getProxyUri(null, proxyUri,
        applicationAttemptId.getApplicationId());
    return result.toASCIIString();
  } catch (URISyntaxException e) {
    LOG.warn("Could not proxify the uri for "
        + applicationAttemptId.getApplicationId(), e);
    return null;
  } finally {
    this.readLock.unlock();
  }
}
开发者ID:naver，项目名称:hadoop，代码行数:18，代码来源:RMAppAttemptImpl.java


示例2: generateProxyUriWithScheme

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
private String generateProxyUriWithScheme(
    final String trackingUriWithoutScheme) {
  this.readLock.lock();
  try {
    final String scheme = WebAppUtils.getHttpSchemePrefix(conf);
    URI trackingUri = StringUtils.isEmpty(trackingUriWithoutScheme) ? null :
      ProxyUriUtils.getUriFromAMUrl(scheme, trackingUriWithoutScheme);
    String proxy = WebAppUtils.getProxyHostAndPort(conf);
    URI proxyUri = ProxyUriUtils.getUriFromAMUrl(scheme, proxy);
    URI result = ProxyUriUtils.getProxyUri(trackingUri, proxyUri,
        applicationAttemptId.getApplicationId());
    return result.toASCIIString();
  } catch (URISyntaxException e) {
    LOG.warn("Could not proxify "+trackingUriWithoutScheme,e);
    return trackingUriWithoutScheme;
  } finally {
    this.readLock.unlock();
  }
}
开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:20，代码来源:RMAppAttemptImpl.java


示例3: getProxyUrl

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
private String getProxyUrl(RMAppAttempt appAttempt) {
  String url = null;
  final String scheme = WebAppUtils.getHttpSchemePrefix(conf);
  try {
    URI trackingUri =
        StringUtils.isEmpty(appAttempt.getOriginalTrackingUrl()) ? null :
            ProxyUriUtils
                .getUriFromAMUrl(scheme, appAttempt.getOriginalTrackingUrl());
    String proxy = WebAppUtils.getProxyHostAndPort(conf);
    URI proxyUri = ProxyUriUtils.getUriFromAMUrl(scheme, proxy);
    URI result = ProxyUriUtils.getProxyUri(trackingUri, proxyUri,
        appAttempt.getAppAttemptId().getApplicationId());
    url = result.toASCIIString();
  } catch (URISyntaxException ex) {
    Assert.fail();
  }
  return url;
}
开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:19，代码来源:TestRMAppAttemptTransitions.java


示例4: generateProxyUriWithoutScheme

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
private String generateProxyUriWithoutScheme(
    final String trackingUriWithoutScheme) {
  this.readLock.lock();
  try {
    URI trackingUri = StringUtils.isEmpty(trackingUriWithoutScheme) ? null :
      ProxyUriUtils.getUriFromAMUrl(trackingUriWithoutScheme);
    String proxy = YarnConfiguration.getProxyHostAndPort(conf);
    URI proxyUri = ProxyUriUtils.getUriFromAMUrl(proxy);
    URI result = ProxyUriUtils.getProxyUri(trackingUri, proxyUri,
        applicationAttemptId.getApplicationId());
    //We need to strip off the scheme to have it match what was there before
    return result.toASCIIString().substring(HttpConfig.getSchemePrefix().length());
  } catch (URISyntaxException e) {
    LOG.warn("Could not proxify "+trackingUriWithoutScheme,e);
    return trackingUriWithoutScheme;
  } finally {
    this.readLock.unlock();
  }
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:20，代码来源:RMAppAttemptImpl.java


示例5: startWepApp

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
protected void startWepApp() {
  Builder<ApplicationMasterService> builder = 
    WebApps.$for("cluster", ApplicationMasterService.class, masterService, "ws").at(
        this.conf.get(YarnConfiguration.RM_WEBAPP_ADDRESS,
        YarnConfiguration.DEFAULT_RM_WEBAPP_ADDRESS)); 
  String proxyHostAndPort = YarnConfiguration.getProxyHostAndPort(conf);
  if(YarnConfiguration.getRMWebAppHostAndPort(conf).
      equals(proxyHostAndPort)) {
    AppReportFetcher fetcher = new AppReportFetcher(conf, getClientRMService());
    builder.withServlet(ProxyUriUtils.PROXY_SERVLET_NAME, 
        ProxyUriUtils.PROXY_PATH_SPEC, WebAppProxyServlet.class);
    builder.withAttribute(WebAppProxy.FETCHER_ATTRIBUTE, fetcher);
    String[] proxyParts = proxyHostAndPort.split(":");
    builder.withAttribute(WebAppProxy.PROXY_HOST_ATTRIBUTE, proxyParts[0]);

  }
  webApp = builder.start(new RMWebApp(this));
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:19，代码来源:ResourceManager.java


示例6: generateProxyUriWithoutScheme

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
private String generateProxyUriWithoutScheme(
    final String trackingUriWithoutScheme) {
  this.readLock.lock();
  try {
    URI trackingUri = StringUtils.isEmpty(trackingUriWithoutScheme) ? null :
      ProxyUriUtils.getUriFromAMUrl(trackingUriWithoutScheme);
    String proxy = WebAppUtils.getProxyHostAndPort(conf);
    URI proxyUri = ProxyUriUtils.getUriFromAMUrl(proxy);
    URI result = ProxyUriUtils.getProxyUri(trackingUri, proxyUri,
        applicationAttemptId.getApplicationId());
    //We need to strip off the scheme to have it match what was there before
    return result.toASCIIString().substring(HttpConfig.getSchemePrefix().length());
  } catch (URISyntaxException e) {
    LOG.warn("Could not proxify "+trackingUriWithoutScheme,e);
    return trackingUriWithoutScheme;
  } finally {
    this.readLock.unlock();
  }
}
开发者ID:chendave，项目名称:hadoop-TCP，代码行数:20，代码来源:RMAppAttemptImpl.java


示例7: startWepApp

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
protected void startWepApp() {
  Builder<ApplicationMasterService> builder = 
      WebApps
          .$for("cluster", ApplicationMasterService.class, masterService,
              "ws")
          .with(conf)
          .withHttpSpnegoPrincipalKey(
              YarnConfiguration.RM_WEBAPP_SPNEGO_USER_NAME_KEY)
          .withHttpSpnegoKeytabKey(
              YarnConfiguration.RM_WEBAPP_SPNEGO_KEYTAB_FILE_KEY)
          .at(WebAppUtils.getRMWebAppURLWithoutScheme(conf)); 
  String proxyHostAndPort = WebAppUtils.getProxyHostAndPort(conf);
  if(WebAppUtils.getResolvedRMWebAppURLWithoutScheme(conf).
      equals(proxyHostAndPort)) {
    AppReportFetcher fetcher = new AppReportFetcher(conf, getClientRMService());
    builder.withServlet(ProxyUriUtils.PROXY_SERVLET_NAME, 
        ProxyUriUtils.PROXY_PATH_SPEC, WebAppProxyServlet.class);
    builder.withAttribute(WebAppProxy.FETCHER_ATTRIBUTE, fetcher);
    String[] proxyParts = proxyHostAndPort.split(":");
    builder.withAttribute(WebAppProxy.PROXY_HOST_ATTRIBUTE, proxyParts[0]);

  }
  webApp = builder.start(new RMWebApp(this));
}
开发者ID:chendave，项目名称:hadoop-TCP，代码行数:25，代码来源:ResourceManager.java


示例8: getProxyUrl

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
private String getProxyUrl(RMAppAttempt appAttempt) {
  String url = null;
  try {
    URI trackingUri =
        StringUtils.isEmpty(appAttempt.getOriginalTrackingUrl()) ? null :
            ProxyUriUtils
                .getUriFromAMUrl(appAttempt.getOriginalTrackingUrl());
    String proxy = WebAppUtils.getProxyHostAndPort(conf);
    URI proxyUri = ProxyUriUtils.getUriFromAMUrl(proxy);
    URI result = ProxyUriUtils.getProxyUri(trackingUri, proxyUri,
        appAttempt.getAppAttemptId().getApplicationId());
    url = result.toASCIIString().substring(
        HttpConfig.getSchemePrefix().length());
  } catch (URISyntaxException ex) {
    Assert.fail();
  }
  return url;
}
开发者ID:chendave，项目名称:hadoop-TCP，代码行数:19，代码来源:TestRMAppAttemptTransitions.java


示例9: getDefaultProxyTrackingUrl

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
private String getDefaultProxyTrackingUrl() {
  try {
    final String scheme = WebAppUtils.getHttpSchemePrefix(conf);
    String proxy = WebAppUtils.getProxyHostAndPort(conf);
    URI proxyUri = ProxyUriUtils.getUriFromAMUrl(scheme, proxy);
    URI result = ProxyUriUtils.getProxyUri(null, proxyUri, applicationId);
    return result.toASCIIString();
  } catch (URISyntaxException e) {
    LOG.warn("Could not generate default proxy tracking URL for "
        + applicationId);
    return UNAVAILABLE;
  }
}
开发者ID:naver，项目名称:hadoop，代码行数:14，代码来源:RMAppImpl.java


示例10: getWebProxyBase

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
@Override
public String getWebProxyBase() {
  this.readLock.lock();
  try {
    return ProxyUriUtils.getPath(applicationAttemptId.getApplicationId());
  } finally {
    this.readLock.unlock();
  }    
}
开发者ID:naver，项目名称:hadoop，代码行数:10，代码来源:RMAppAttemptImpl.java


示例11: getProxyUrl

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
private String getProxyUrl(RMAppAttempt appAttempt) {
  String url = null;
  final String scheme = WebAppUtils.getHttpSchemePrefix(conf);
  try {
    String proxy = WebAppUtils.getProxyHostAndPort(conf);
    URI proxyUri = ProxyUriUtils.getUriFromAMUrl(scheme, proxy);
    URI result = ProxyUriUtils.getProxyUri(null, proxyUri, appAttempt
        .getAppAttemptId().getApplicationId());
    url = result.toASCIIString();
  } catch (URISyntaxException ex) {
    Assert.fail();
  }
  return url;
}
开发者ID:naver，项目名称:hadoop，代码行数:15，代码来源:TestRMAppAttemptTransitions.java


示例12: testMRWebAppRedirection

import org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils; //导入依赖的package包/类
@Test
public void testMRWebAppRedirection() throws Exception {

  String[] schemePrefix =
      { WebAppUtils.HTTP_PREFIX, WebAppUtils.HTTPS_PREFIX };
  for (String scheme : schemePrefix) {
    MRApp app = new MRApp(2, 2, true, this.getClass().getName(), true) {
      @Override
      protected ClientService createClientService(AppContext context) {
        return new MRClientService(context);
      }
    };
    Configuration conf = new Configuration();
    conf.set(YarnConfiguration.PROXY_ADDRESS, "9.9.9.9");
    conf.set(YarnConfiguration.YARN_HTTP_POLICY_KEY, scheme
      .equals(WebAppUtils.HTTPS_PREFIX) ? Policy.HTTPS_ONLY.name()
        : Policy.HTTP_ONLY.name());
    webProxyBase = "/proxy/" + app.getAppID();
    conf.set("hadoop.http.filter.initializers",
      TestAMFilterInitializer.class.getName());
    Job job = app.submit(conf);
    String hostPort =
        NetUtils.getHostPortString(((MRClientService) app.getClientService())
          .getWebApp().getListenerAddress());
    URL httpUrl = new URL("http://" + hostPort + "/mapreduce");

    HttpURLConnection conn = (HttpURLConnection) httpUrl.openConnection();
    conn.setInstanceFollowRedirects(false);
    conn.connect();
    String expectedURL =
        scheme + conf.get(YarnConfiguration.PROXY_ADDRESS)
            + ProxyUriUtils.getPath(app.getAppID(), "/mapreduce");
    Assert.assertEquals(expectedURL,
      conn.getHeaderField(HttpHeaders.LOCATION));
    Assert.assertEquals(HttpStatus.SC_MOVED_TEMPORARILY,
      conn.getResponseCode());
    app.waitForState(job, JobState.SUCCEEDED);
    app.verifyCompleted();
  }
}
开发者ID:naver，项目名称:hadoop，代码行数:41，代码来源:TestAMWebApp.java



注：本文中的org.apache.hadoop.yarn.server.webproxy.ProxyUriUtils类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java FailureAnalysis类代码示例发布时间：2022-05-22
下一篇：
Java InvalidOperationException类代码示例发布时间：2022-05-22
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap