Package org.apache.hadoop.mapreduce.v2.app.webapp

Class AMWebServices

java.lang.Object

org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices

@Singleton
@Path("/ws/v1/mapreduce")
public class AMWebServices
extends Object

Constructor Summary

Constructors

Constructor	Description
AMWebServices(App app, AppContext context)

Method Summary

Modifier and Type	Method	Description
AppInfo	get()
AppInfo	getAppInfo()
BlacklistedNodesInfo	getBlacklistedNodes()
JobInfo	getJob(javax.servlet.http.HttpServletRequest hsr, String jid)
AMAttemptsInfo	getJobAttempts(String jid)
ConfInfo	getJobConf(javax.servlet.http.HttpServletRequest hsr, String jid)
JobCounterInfo	getJobCounters(javax.servlet.http.HttpServletRequest hsr, String jid)
static Job	getJobFromContainerIdString(String cid, AppContext appCtx)
static Job	getJobFromJobIdString(String jid, AppContext appCtx)	convert a job id string to an actual job and handle all the error checking.
JobsInfo	getJobs(javax.servlet.http.HttpServletRequest hsr)
TaskInfo	getJobTask(javax.servlet.http.HttpServletRequest hsr, String jid, String tid)
TaskAttemptInfo	getJobTaskAttemptId(javax.servlet.http.HttpServletRequest hsr, String jid, String tid, String attId)
JobTaskAttemptCounterInfo	getJobTaskAttemptIdCounters(javax.servlet.http.HttpServletRequest hsr, String jid, String tid, String attId)
TaskAttemptsInfo	getJobTaskAttempts(javax.servlet.http.HttpServletRequest hsr, String jid, String tid)
JobTaskAttemptState	getJobTaskAttemptState(javax.servlet.http.HttpServletRequest hsr, String jid, String tid, String attId)
TasksInfo	getJobTasks(javax.servlet.http.HttpServletRequest hsr, String jid, String type)
JobTaskCounterInfo	getSingleTaskCounters(javax.servlet.http.HttpServletRequest hsr, String jid, String tid)
static TaskAttempt	getTaskAttemptFromTaskAttemptString(String attId, Task task)	convert a task attempt id string to an actual task attempt and handle all the error checking.
static Task	getTaskFromTaskIdString(String tid, Job job)	convert a task id string to an actual task and handle all the error checking.
protected javax.ws.rs.core.Response	killJobTaskAttempt(TaskAttempt ta, org.apache.hadoop.security.UserGroupInformation callerUGI, javax.servlet.http.HttpServletRequest hsr)
javax.ws.rs.core.Response	updateJobTaskAttemptState(JobTaskAttemptState targetState, javax.servlet.http.HttpServletRequest hsr, String jid, String tid, String attId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AMWebServices

@Inject
public AMWebServices(@Named("app")
 App app,
 @Named("am")
 AppContext context)

Method Details

getJobFromContainerIdString

public static Job getJobFromContainerIdString(String cid,
 AppContext appCtx)
                                       throws org.apache.hadoop.yarn.webapp.NotFoundException

Throws:

org.apache.hadoop.yarn.webapp.NotFoundException

getJobFromJobIdString

public static Job getJobFromJobIdString(String jid,
 AppContext appCtx)
                                 throws org.apache.hadoop.yarn.webapp.NotFoundException

convert a job id string to an actual job and handle all the error checking.

Throws:

org.apache.hadoop.yarn.webapp.NotFoundException

getTaskFromTaskIdString

public static Task getTaskFromTaskIdString(String tid,
 Job job)
                                    throws org.apache.hadoop.yarn.webapp.NotFoundException

convert a task id string to an actual task and handle all the error checking.

Throws:

org.apache.hadoop.yarn.webapp.NotFoundException

getTaskAttemptFromTaskAttemptString

public static TaskAttempt getTaskAttemptFromTaskAttemptString(String attId,
 Task task)
                                                       throws org.apache.hadoop.yarn.webapp.NotFoundException

convert a task attempt id string to an actual task attempt and handle all the error checking.

Throws:

org.apache.hadoop.yarn.webapp.NotFoundException

get

@GET
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public AppInfo get()

getAppInfo

@GET
@Path("/info")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public AppInfo getAppInfo()

getBlacklistedNodes

@GET
@Path("/blacklistednodes")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public BlacklistedNodesInfo getBlacklistedNodes()

getJobs

@GET
@Path("/jobs")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public JobsInfo getJobs(@Context
 javax.servlet.http.HttpServletRequest hsr)

getJob

@GET
@Path("/jobs/{jobid}")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public JobInfo getJob(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid)

getJobAttempts

@GET
@Path("/jobs/{jobid}/jobattempts")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public AMAttemptsInfo getJobAttempts(@PathParam("jobid")
 String jid)

getJobCounters

@GET
@Path("/jobs/{jobid}/counters")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public JobCounterInfo getJobCounters(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid)

getJobConf

@GET
@Path("/jobs/{jobid}/conf")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public ConfInfo getJobConf(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid)

getJobTasks

@GET
@Path("/jobs/{jobid}/tasks")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public TasksInfo getJobTasks(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid,
 @QueryParam("type")
 String type)

getJobTask

@GET
@Path("/jobs/{jobid}/tasks/{taskid}")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public TaskInfo getJobTask(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid,
 @PathParam("taskid")
 String tid)

getSingleTaskCounters

@GET
@Path("/jobs/{jobid}/tasks/{taskid}/counters")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public JobTaskCounterInfo getSingleTaskCounters(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid,
 @PathParam("taskid")
 String tid)

getJobTaskAttempts

@GET
@Path("/jobs/{jobid}/tasks/{taskid}/attempts")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public TaskAttemptsInfo getJobTaskAttempts(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid,
 @PathParam("taskid")
 String tid)

getJobTaskAttemptId

@GET
@Path("/jobs/{jobid}/tasks/{taskid}/attempts/{attemptid}")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public TaskAttemptInfo getJobTaskAttemptId(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid,
 @PathParam("taskid")
 String tid,
 @PathParam("attemptid")
 String attId)

getJobTaskAttemptState

@GET
@Path("/jobs/{jobid}/tasks/{taskid}/attempts/{attemptid}/state")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public JobTaskAttemptState getJobTaskAttemptState(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid,
 @PathParam("taskid")
 String tid,
 @PathParam("attemptid")
 String attId)
                                           throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

updateJobTaskAttemptState

@PUT
@Path("/jobs/{jobid}/tasks/{taskid}/attempts/{attemptid}/state")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
@Consumes({"application/json","application/xml"})
public javax.ws.rs.core.Response updateJobTaskAttemptState(JobTaskAttemptState targetState,
 @Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid,
 @PathParam("taskid")
 String tid,
 @PathParam("attemptid")
 String attId)
                                                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getJobTaskAttemptIdCounters

@GET
@Path("/jobs/{jobid}/tasks/{taskid}/attempts/{attemptid}/counters")
@Produces({"application/json; charset=utf-8","application/xml; charset=utf-8"})
public JobTaskAttemptCounterInfo getJobTaskAttemptIdCounters(@Context
 javax.servlet.http.HttpServletRequest hsr,
 @PathParam("jobid")
 String jid,
 @PathParam("taskid")
 String tid,
 @PathParam("attemptid")
 String attId)

killJobTaskAttempt

protected javax.ws.rs.core.Response killJobTaskAttempt(TaskAttempt ta,
 org.apache.hadoop.security.UserGroupInformation callerUGI,
 javax.servlet.http.HttpServletRequest hsr)
                                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException