Java 类org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptsInfo 实例源码

项目：hadoop 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}

项目：aliyun-oss-hadoop-fs 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}

项目：big-c 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}

项目：hadoop-plus 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}

项目：FlexMap 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}

项目：hops 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}

项目：hadoop-TCP 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}

项目：hardfs 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}

项目：hadoop-on-lustre2 文件：AMWebServices.java

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
public AMAttemptsInfo getJobAttempts(@PathParam("jobid") String jid) {
  init();
  Job job = getJobFromJobIdString(jid, appCtx);
  AMAttemptsInfo amAttempts = new AMAttemptsInfo();
  for (AMInfo amInfo : job.getAMInfos()) {
    AMAttemptInfo attempt = new AMAttemptInfo(amInfo, MRApps.toString(
          job.getID()), job.getUserName());
    amAttempts.add(attempt);
  }
  return amAttempts;
}