Java GetJobReportRequest类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: getJobReport

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportRequest; //导入依赖的package包/类
@Override
public GetJobReportResponse getJobReport(GetJobReportRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  // false is for retain compatibility
  Job job = verifyAndGetJob(jobId, JobACL.VIEW_JOB, false);
  GetJobReportResponse response = 
    recordFactory.newRecordInstance(GetJobReportResponse.class);
  if (job != null) {
    response.setJobReport(job.getReport());
  }
  else {
    response.setJobReport(null);
  }
  return response;
}

开发者ID:naver，项目名称:hadoop，代码行数:17，代码来源:MRClientService.java

示例2: getJobReport

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportRequest; //导入依赖的package包/类
@Override
public GetJobReportResponse getJobReport(GetJobReportRequest request)
    throws IOException {
  JobReport jobReport =
    recordFactory.newRecordInstance(JobReport.class);
  jobReport.setJobId(request.getJobId());
  jobReport.setJobState(jobState);
  jobReport.setUser(applicationReport.getUser());
  jobReport.setStartTime(applicationReport.getStartTime());
  jobReport.setDiagnostics(applicationReport.getDiagnostics());
  jobReport.setJobName(applicationReport.getName());
  jobReport.setTrackingUrl(applicationReport.getTrackingUrl());
  jobReport.setFinishTime(applicationReport.getFinishTime());

  GetJobReportResponse resp =
      recordFactory.newRecordInstance(GetJobReportResponse.class);
  resp.setJobReport(jobReport);
  return resp;
}

开发者ID:naver，项目名称:hadoop，代码行数:20，代码来源:NotRunningJob.java

示例3: getJobStatus

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportRequest; //导入依赖的package包/类
public JobStatus getJobStatus(JobID oldJobID) throws IOException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobId =
    TypeConverter.toYarn(oldJobID);
  GetJobReportRequest request =
      recordFactory.newRecordInstance(GetJobReportRequest.class);
  request.setJobId(jobId);
  JobReport report = ((GetJobReportResponse) invoke("getJobReport",
      GetJobReportRequest.class, request)).getJobReport();
  JobStatus jobStatus = null;
  if (report != null) {
    if (StringUtils.isEmpty(report.getJobFile())) {
      String jobFile = MRApps.getJobFile(conf, report.getUser(), oldJobID);
      report.setJobFile(jobFile);
    }
    String historyTrackingUrl = report.getTrackingUrl();
    String url = StringUtils.isNotEmpty(historyTrackingUrl)
        ? historyTrackingUrl : trackingUrl;
    jobStatus = TypeConverter.fromYarn(report, url);
  }
  return jobStatus;
}

开发者ID:naver，项目名称:hadoop，代码行数:22，代码来源:ClientServiceDelegate.java

示例4: testRetriesOnConnectionFailure

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportRequest; //导入依赖的package包/类
@Test
public void testRetriesOnConnectionFailure() throws Exception {

  MRClientProtocol historyServerProxy = mock(MRClientProtocol.class);
  when(historyServerProxy.getJobReport(getJobReportRequest())).thenThrow(
      new RuntimeException("1")).thenThrow(new RuntimeException("2"))       
      .thenReturn(getJobReportResponse());

  ResourceMgrDelegate rm = mock(ResourceMgrDelegate.class);
  when(rm.getApplicationReport(TypeConverter.toYarn(oldJobId).getAppId()))
      .thenReturn(null);

  ClientServiceDelegate clientServiceDelegate = getClientServiceDelegate(
      historyServerProxy, rm);

  JobStatus jobStatus = clientServiceDelegate.getJobStatus(oldJobId);
  Assert.assertNotNull(jobStatus);
  verify(historyServerProxy, times(3)).getJobReport(
      any(GetJobReportRequest.class));
}

开发者ID:naver，项目名称:hadoop，代码行数:21，代码来源:TestClientServiceDelegate.java

示例5: getJobReport

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportRequest; //导入依赖的package包/类
@Override
public GetJobReportResponse getJobReport(GetJobReportRequest request)
    throws IOException {

  amContact = true;

  JobReport jobReport = recordFactory.newRecordInstance(JobReport.class);
  jobReport.setJobId(request.getJobId());
  jobReport.setJobState(JobState.RUNNING);
  jobReport.setJobName("TestClientRedirect-jobname");
  jobReport.setUser("TestClientRedirect-user");
  jobReport.setStartTime(0L);
  jobReport.setFinishTime(1L);

  GetJobReportResponse response = recordFactory
      .newRecordInstance(GetJobReportResponse.class);
  response.setJobReport(jobReport);
  return response;
}

开发者ID:naver，项目名称:hadoop，代码行数:20，代码来源:TestClientRedirect.java

示例6: getJobStatus

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportRequest; //导入依赖的package包/类
public JobStatus getJobStatus(JobID oldJobID) throws IOException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobId =
    TypeConverter.toYarn(oldJobID);
  GetJobReportRequest request =
      recordFactory.newRecordInstance(GetJobReportRequest.class);
  request.setJobId(jobId);
  JobReport report = ((GetJobReportResponse) invoke("getJobReport",
      GetJobReportRequest.class, request)).getJobReport();
  JobStatus jobStatus = null;
  if (report != null) {
    if (StringUtils.isEmpty(report.getJobFile())) {
      String jobFile = MRApps.getJobFile(conf, report.getUser(), oldJobID);
      report.setJobFile(jobFile);
    }
    String historyTrackingUrl = report.getTrackingUrl();
    String url = StringUtils.isNotEmpty(historyTrackingUrl)
        ? historyTrackingUrl : trackingUrl;
    if (!UNAVAILABLE.equals(url)) {
      url = HttpConfig.getSchemePrefix() + url;
    }
    jobStatus = TypeConverter.fromYarn(report, url);
  }
  return jobStatus;
}

开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:25，代码来源:ClientServiceDelegate.java

示例7: getJobReport

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportRequest; //导入依赖的package包/类
@Override
public GetJobReportResponse getJobReport(GetJobReportRequest request)
    throws IOException {
  JobReport jobReport =
    recordFactory.newRecordInstance(JobReport.class);
  jobReport.setJobId(request.getJobId());
  jobReport.setJobState(jobState);
  jobReport.setUser(applicationReport.getUser());
  jobReport.setStartTime(applicationReport.getStartTime());
  YarnApplicationState state = applicationReport.getYarnApplicationState();
  if (state == YarnApplicationState.KILLED
      || state == YarnApplicationState.FAILED
      || state == YarnApplicationState.FINISHED) {
    jobReport.setDiagnostics(applicationReport.getDiagnostics());
  }
  jobReport.setJobName(applicationReport.getName());
  jobReport.setTrackingUrl(applicationReport.getTrackingUrl());
  jobReport.setFinishTime(applicationReport.getFinishTime());

  GetJobReportResponse resp =
      recordFactory.newRecordInstance(GetJobReportResponse.class);
  resp.setJobReport(jobReport);
  return resp;
}

开发者ID:hopshadoop，项目名称:hops，代码行数:25，代码来源:NotRunningJob.java

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