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

Java GetContainerReportResponse类代码示例

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

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



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

示例1: testGetContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Test
public void testGetContainerReport() throws YarnException, IOException {
  ClientRMService rmService = createRMService();
  RecordFactory recordFactory = RecordFactoryProvider.getRecordFactory(null);
  GetContainerReportRequest request = recordFactory
      .newRecordInstance(GetContainerReportRequest.class);
  ApplicationAttemptId attemptId = ApplicationAttemptId.newInstance(
      ApplicationId.newInstance(123456, 1), 1);
  ContainerId containerId = ContainerId.newContainerId(attemptId, 1);
  request.setContainerId(containerId);

  try {
    GetContainerReportResponse response = rmService
        .getContainerReport(request);
    Assert.assertEquals(containerId, response.getContainerReport()
        .getContainerId());
  } catch (ApplicationNotFoundException ex) {
    Assert.fail(ex.getMessage());
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:21,代码来源:TestClientRMService.java


示例2: testContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Test
public void testContainerReport() throws IOException, YarnException {
  ApplicationId appId = ApplicationId.newInstance(0, 1);
  ApplicationAttemptId appAttemptId =
      ApplicationAttemptId.newInstance(appId, 1);
  ContainerId containerId = ContainerId.newContainerId(appAttemptId, 1);
  GetContainerReportRequest request =
      GetContainerReportRequest.newInstance(containerId);
  GetContainerReportResponse response =
      clientService.getContainerReport(request);
  ContainerReport container = response.getContainerReport();
  Assert.assertNotNull(container);
  Assert.assertEquals(containerId, container.getContainerId());
  Assert.assertEquals("http://0.0.0.0:8188/applicationhistory/logs/" +
      "test host:100/container_0_0001_01_000001/" +
      "container_0_0001_01_000001/user1", container.getLogUrl());
}
 
开发者ID:naver,项目名称:hadoop,代码行数:18,代码来源:TestApplicationHistoryClientService.java


示例3: getContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Override
public ContainerReport getContainerReport(ContainerId containerId)
    throws YarnException, IOException {
  try {
    GetContainerReportRequest request = Records
        .newRecord(GetContainerReportRequest.class);
    request.setContainerId(containerId);
    GetContainerReportResponse response = rmClient
        .getContainerReport(request);
    return response.getContainerReport();
  } catch (YarnException e) {
    if (!historyServiceEnabled) {
      // Just throw it as usual if historyService is not enabled.
      throw e;
    }
    // Even if history-service is enabled, treat all exceptions still the same
    // except the following
    if (e.getClass() != ApplicationNotFoundException.class
        && e.getClass() != ContainerNotFoundException.class) {
      throw e;
    }
    return historyClient.getContainerReport(containerId);
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:25,代码来源:YarnClientImpl.java


示例4: testContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Test
public void testContainerReport() throws IOException, YarnException {
  ApplicationId appId = ApplicationId.newInstance(0, 1);
  ApplicationAttemptId appAttemptId =
      ApplicationAttemptId.newInstance(appId, 1);
  ContainerId containerId = ContainerId.newContainerId(appAttemptId, 1);
  GetContainerReportRequest request =
      GetContainerReportRequest.newInstance(containerId);
  GetContainerReportResponse response =
      clientService.getClientHandler().getContainerReport(request);
  ContainerReport container = response.getContainerReport();
  Assert.assertNotNull(container);
  Assert.assertEquals(containerId, container.getContainerId());
  Assert.assertEquals("http://0.0.0.0:8188/applicationhistory/logs/" +
      "test host:100/container_0_0001_01_000001/" +
      "container_0_0001_01_000001/user1", container.getLogUrl());
}
 
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:18,代码来源:TestApplicationHistoryClientService.java


示例5: getContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Override
public ContainerReport getContainerReport(ContainerId containerId)
    throws YarnException, IOException {
  try {
    GetContainerReportRequest request = Records
        .newRecord(GetContainerReportRequest.class);
    request.setContainerId(containerId);
    GetContainerReportResponse response = rmClient
        .getContainerReport(request);
    return response.getContainerReport();
  } catch (YarnException e) {
    if (!historyServiceEnabled) {
      // Just throw it as usual if historyService is not enabled.
      throw e;
    }
    // Even if history-service is enabled, treat all exceptions still the same
    // except the following
    if (e.getClass() != ApplicationNotFoundException.class) {
      throw e;
    }
    return historyClient.getContainerReport(containerId);
  }
}
 
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:24,代码来源:YarnClientImpl.java


示例6: testGetContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Test
public void testGetContainerReport() throws YarnException, IOException {
  ClientRMService rmService = createRMService();
  RecordFactory recordFactory = RecordFactoryProvider.getRecordFactory(null);
  GetContainerReportRequest request = recordFactory
      .newRecordInstance(GetContainerReportRequest.class);
  ApplicationAttemptId attemptId = ApplicationAttemptId.newInstance(
      ApplicationId.newInstance(123456, 1), 1);
  ContainerId containerId = ContainerId.newInstance(attemptId, 1);
  request.setContainerId(containerId);

  try {
    GetContainerReportResponse response = rmService
        .getContainerReport(request);
    Assert.assertEquals(containerId, response.getContainerReport()
        .getContainerId());
  } catch (ApplicationNotFoundException ex) {
    Assert.fail(ex.getMessage());
  }
}
 
开发者ID:Seagate,项目名称:hadoop-on-lustre2,代码行数:21,代码来源:TestClientRMService.java


示例7: testContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Test
public void testContainerReport() throws IOException, YarnException {
  ApplicationId appId = ApplicationId.newInstance(0, 1);
  writeApplicationStartData(appId);
  ApplicationAttemptId appAttemptId =
      ApplicationAttemptId.newInstance(appId, 1);
  ContainerId containerId = ContainerId.newInstance(appAttemptId, 1);
  writeContainerStartData(containerId);
  writeContainerFinishData(containerId);
  writeApplicationFinishData(appId);
  GetContainerReportRequest request =
      GetContainerReportRequest.newInstance(containerId);
  GetContainerReportResponse response =
      historyServer.getClientService().getClientHandler()
        .getContainerReport(request);
  ContainerReport container = response.getContainerReport();
  Assert.assertNotNull(container);
  Assert.assertEquals(containerId, container.getContainerId());
  Assert.assertEquals(expectedLogUrl, container.getLogUrl());
}
 
开发者ID:Seagate,项目名称:hadoop-on-lustre2,代码行数:21,代码来源:TestApplicationHistoryClientService.java


示例8: getContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Override
public GetContainerReportResponse getContainerReport(
    GetContainerReportRequest request) throws YarnException, IOException {
  GetContainerReportRequestProto requestProto =
      ((GetContainerReportRequestPBImpl) request).getProto();
  try {
    return new GetContainerReportResponsePBImpl(proxy.getContainerReport(
      null, requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:14,代码来源:ApplicationHistoryProtocolPBClientImpl.java


示例9: getContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Override
public GetContainerReportResponse getContainerReport(
    GetContainerReportRequest request) throws YarnException, IOException {
  ContainerId containerId = request.getContainerId();
  try {
    GetContainerReportResponse response =
        GetContainerReportResponse.newInstance(history
          .getContainer(containerId));
    return response;
  } catch (IOException e) {
    LOG.error(e.getMessage(), e);
    throw e;
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:15,代码来源:ApplicationHistoryClientService.java


示例10: getContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Override
public ContainerReport getContainerReport(ContainerId containerId)
    throws YarnException, IOException {
  GetContainerReportRequest request = GetContainerReportRequest
      .newInstance(containerId);
  GetContainerReportResponse response = ahsClient.getContainerReport(request);
  return response.getContainerReport();
}
 
开发者ID:naver,项目名称:hadoop,代码行数:9,代码来源:AHSClientImpl.java


示例11: getContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Override
public GetContainerReportResponse getContainerReport(
    GetContainerReportRequest request) throws YarnException,
        IOException {
  resetStartFailoverFlag(true);

  // make sure failover has been triggered
  Assert.assertTrue(waittingForFailOver());

  // return fake containerReport
  return GetContainerReportResponse
      .newInstance(createFakeContainerReport());
}
 
开发者ID:naver,项目名称:hadoop,代码行数:14,代码来源:ProtocolHATestBase.java


示例12: getContainerReport

import org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse; //导入依赖的package包/类
@Override
public GetContainerReportResponse getContainerReport(
    GetContainerReportRequest request) throws YarnException, IOException {
  try {
    GetContainerReportResponse response =
        GetContainerReportResponse.newInstance(history.getContainer(request
          .getContainerId()));
    return response;
  } catch (IOException e) {
    throw new ContainerNotFoundException(e.getMessage());
  }
}
 
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:13,代码来源:ApplicationHistoryClientService.java



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


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java AuthnRequest类代码示例发布时间:2022-05-22
下一篇:
Java ContainerResourceFailedEvent类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

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

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