org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskReportRequest#getTaskId ( )源码实例Demo

下面列出了org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskReportRequest#getTaskId ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： hadoop 文件： MRClientService.java

@Override
public GetTaskReportResponse getTaskReport(GetTaskReportRequest request) 
  throws IOException {
  TaskId taskId = request.getTaskId();
  GetTaskReportResponse response = 
    recordFactory.newRecordInstance(GetTaskReportResponse.class);
  response.setTaskReport(
      verifyAndGetTask(taskId, JobACL.VIEW_JOB).getReport());
  return response;
}

源代码2 项目： hadoop 文件： HistoryClientService.java

@Override
public GetTaskReportResponse getTaskReport(GetTaskReportRequest request)
    throws IOException {
  TaskId taskId = request.getTaskId();
  Job job = verifyAndGetJob(taskId.getJobId(), true);
  GetTaskReportResponse response = recordFactory.newRecordInstance(GetTaskReportResponse.class);
  response.setTaskReport(job.getTask(taskId).getReport());
  return response;
}

源代码3 项目： big-c 文件： MRClientService.java

@Override
public GetTaskReportResponse getTaskReport(GetTaskReportRequest request) 
  throws IOException {
  TaskId taskId = request.getTaskId();
  GetTaskReportResponse response = 
    recordFactory.newRecordInstance(GetTaskReportResponse.class);
  response.setTaskReport(
      verifyAndGetTask(taskId, JobACL.VIEW_JOB).getReport());
  return response;
}

源代码4 项目： big-c 文件： HistoryClientService.java

@Override
public GetTaskReportResponse getTaskReport(GetTaskReportRequest request)
    throws IOException {
  TaskId taskId = request.getTaskId();
  Job job = verifyAndGetJob(taskId.getJobId(), true);
  GetTaskReportResponse response = recordFactory.newRecordInstance(GetTaskReportResponse.class);
  response.setTaskReport(job.getTask(taskId).getReport());
  return response;
}

方法所在类

org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskReportRequest