Java GetJobReportResponse类代码示例

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

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

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

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

示例1: getJobReport

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportResponse; //导入依赖的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.GetJobReportResponse; //导入依赖的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.GetJobReportResponse; //导入依赖的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: getJobReport

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportResponse; //导入依赖的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

示例5: getJobStatus

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportResponse; //导入依赖的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

示例6: getJobReport

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportResponse; //导入依赖的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

示例7: getJobReportResponse

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportResponse; //导入依赖的package包/类
private GetJobReportResponse getJobReportResponse() {
  GetJobReportResponse jobReportResponse = Records
      .newRecord(GetJobReportResponse.class);
  JobReport jobReport = Records.newRecord(JobReport.class);
  jobReport.setJobId(jobId);
  jobReport.setJobState(JobState.SUCCEEDED);
  jobReportResponse.setJobReport(jobReport);
  return jobReportResponse;
}

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

示例8: getJobReportResponseFromHistoryServer

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportResponse; //导入依赖的package包/类
private GetJobReportResponse getJobReportResponseFromHistoryServer() {
  GetJobReportResponse jobReportResponse = Records                                              
      .newRecord(GetJobReportResponse.class);                                                   
  JobReport jobReport = Records.newRecord(JobReport.class);                                     
  jobReport.setJobId(jobId);                                                                    
  jobReport.setJobState(JobState.SUCCEEDED);                                                    
  jobReport.setMapProgress(1.0f);
  jobReport.setReduceProgress(1.0f);
  jobReport.setJobFile("TestJobFilePath");
  jobReport.setTrackingUrl("http://TestTrackingUrl");
  jobReportResponse.setJobReport(jobReport);
  return jobReportResponse;
}

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

示例9: getJobReport

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportResponse; //导入依赖的package包/类
@Override
public GetJobReportResponseProto getJobReport(RpcController controller,
    GetJobReportRequestProto proto) throws ServiceException {
  GetJobReportRequestPBImpl request = new GetJobReportRequestPBImpl(proto);
  try {
    GetJobReportResponse response = real.getJobReport(request);
    return ((GetJobReportResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

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

示例10: getJobReport

import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportResponse; //导入依赖的package包/类
@Override
public GetJobReportResponse getJobReport(GetJobReportRequest request)
    throws IOException {
  GetJobReportRequestProto requestProto = ((GetJobReportRequestPBImpl)request).getProto();
  try {
    return new GetJobReportResponsePBImpl(proxy.getJobReport(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

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

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