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

Class AMWebServices

java.lang.Object

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

public class AMWebServices
extends Object

Constructor Summary

Constructors

Constructor and Description
AMWebServices(App app, AppContext context)

Method Summary

Modifier and Type	Method and 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	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 Detail

AMWebServices

@Inject
public AMWebServices(App app,
                             AppContext context)

Method Detail

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

public AppInfo get()

getAppInfo

public AppInfo getAppInfo()

getBlacklistedNodes

public BlacklistedNodesInfo getBlacklistedNodes()

getJobs

public JobsInfo getJobs(@Context
                        javax.servlet.http.HttpServletRequest hsr)

getJob

public JobInfo getJob(@Context
                      javax.servlet.http.HttpServletRequest hsr,
                      String jid)

getJobAttempts

public AMAttemptsInfo getJobAttempts(String jid)

getJobCounters

public JobCounterInfo getJobCounters(@Context
                                     javax.servlet.http.HttpServletRequest hsr,
                                     String jid)

getJobConf

public ConfInfo getJobConf(@Context
                           javax.servlet.http.HttpServletRequest hsr,
                           String jid)

getJobTasks

public TasksInfo getJobTasks(@Context
                             javax.servlet.http.HttpServletRequest hsr,
                             String jid,
                             String type)

getJobTask

public TaskInfo getJobTask(@Context
                           javax.servlet.http.HttpServletRequest hsr,
                           String jid,
                           String tid)

getSingleTaskCounters

public JobTaskCounterInfo getSingleTaskCounters(@Context
                                                javax.servlet.http.HttpServletRequest hsr,
                                                String jid,
                                                String tid)

getJobTaskAttempts

public TaskAttemptsInfo getJobTaskAttempts(@Context
                                           javax.servlet.http.HttpServletRequest hsr,
                                           String jid,
                                           String tid)

getJobTaskAttemptId

public TaskAttemptInfo getJobTaskAttemptId(@Context
                                           javax.servlet.http.HttpServletRequest hsr,
                                           String jid,
                                           String tid,
                                           String attId)

getJobTaskAttemptState

public JobTaskAttemptState getJobTaskAttemptState(@Context
                                                  javax.servlet.http.HttpServletRequest hsr,
                                                  String jid,
                                                  String tid,
                                                  String attId)
                                           throws IOException,
                                                  InterruptedException

Throws:

IOException

InterruptedException

updateJobTaskAttemptState

public javax.ws.rs.core.Response updateJobTaskAttemptState(JobTaskAttemptState targetState,
                                                           @Context
                                                           javax.servlet.http.HttpServletRequest hsr,
                                                           String jid,
                                                           String tid,
                                                           String attId)
                                                    throws IOException,
                                                           InterruptedException

Throws:

IOException

InterruptedException

getJobTaskAttemptIdCounters

public JobTaskAttemptCounterInfo getJobTaskAttemptIdCounters(@Context
                                                             javax.servlet.http.HttpServletRequest hsr,
                                                             String jid,
                                                             String tid,
                                                             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