org.apache.hadoop.mapreduce.v2.hs.webapp

Class HsWebServices

java.lang.Object

org.apache.hadoop.yarn.server.webapp.WebServices

org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices

All Implemented Interfaces:

org.apache.hadoop.yarn.server.webapp.AppInfoProvider

public class HsWebServices
extends org.apache.hadoop.yarn.server.webapp.WebServices

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.webapp.WebServices

appBaseProt

Constructor Summary

Constructors

Constructor and Description
HsWebServices(HistoryContext ctx, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.yarn.webapp.WebApp webapp, org.apache.hadoop.yarn.api.ApplicationClientProtocol appBaseProto)

Method Summary

Modifier and Type	Method and Description
HistoryInfo	get()
javax.ws.rs.core.Response	getAggregatedLogsMeta(javax.servlet.http.HttpServletRequest hsr, String fileName, Set<String> fileSize, Set<String> modificationTime, String appIdStr, String containerIdStr, String nmId)
javax.ws.rs.core.Response	getAggregatedLogsMeta(javax.servlet.http.HttpServletRequest hsr, String appIdStr, String appAttemptIdStr, String containerIdStr, String nmId, boolean redirectedFromNode, boolean manualRedirection)
javax.ws.rs.core.Response	getContainerLogFile(javax.servlet.http.HttpServletRequest req, String containerIdStr, String filename, String format, String size, String nmId, boolean redirectedFromNode, boolean manualRedirection)
javax.ws.rs.core.Response	getContainerLogs(javax.servlet.http.HttpServletRequest hsr, String containerIdStr, String nmId, boolean redirectedFromNode, boolean manualRedirection)
HistoryInfo	getHistoryInfo()
JobInfo	getJob(javax.servlet.http.HttpServletRequest hsr, String jid)
AMAttemptsInfo	getJobAttempts(String jid)
org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfInfo	getJobConf(javax.servlet.http.HttpServletRequest hsr, String jid)
org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobCounterInfo	getJobCounters(javax.servlet.http.HttpServletRequest hsr, String jid)
JobsInfo	getJobs(String userQuery, String count, String stateQuery, String queueQuery, String startedBegin, String startedEnd, String finishBegin, String finishEnd)
org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo	getJobTask(javax.servlet.http.HttpServletRequest hsr, String jid, String tid)
org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo	getJobTaskAttemptId(javax.servlet.http.HttpServletRequest hsr, String jid, String tid, String attId)
org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptCounterInfo	getJobTaskAttemptIdCounters(javax.servlet.http.HttpServletRequest hsr, String jid, String tid, String attId)
org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptsInfo	getJobTaskAttempts(javax.servlet.http.HttpServletRequest hsr, String jid, String tid)
org.apache.hadoop.mapreduce.v2.app.webapp.dao.TasksInfo	getJobTasks(javax.servlet.http.HttpServletRequest hsr, String jid, String type)
javax.ws.rs.core.Response	getRemoteLogDirPath(javax.servlet.http.HttpServletRequest req, String user, String appIdStr) Returns the user qualified path name of the remote log directory for each pre-configured log aggregation file controller.
org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskCounterInfo	getSingleTaskCounters(javax.servlet.http.HttpServletRequest hsr, String jid, String tid)

Methods inherited from class org.apache.hadoop.yarn.server.webapp.WebServices

getApp, getApp, getApp, getAppAttempt, getAppAttempts, getApplicationAttemptReport, getApplicationAttemptsReport, getApplicationReport, getApplicationsReport, getApps, getContainer, getContainer, getContainerReport, getContainers, getContainersReport, getNodeHttpAddress, getUser, initForReadableEndpoints, parseApplicationAttemptId, parseApplicationId, parseContainerId, parseQueries, validateIds

Methods inherited from class java.lang.Object

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

Constructor Detail

HsWebServices

@Inject
public HsWebServices(HistoryContext ctx,
                             org.apache.hadoop.conf.Configuration conf,
                             org.apache.hadoop.yarn.webapp.WebApp webapp,
                             @Nullable
                             org.apache.hadoop.yarn.api.ApplicationClientProtocol appBaseProto)

Method Detail

get

public HistoryInfo get()

getHistoryInfo

public HistoryInfo getHistoryInfo()

getJobs

public JobsInfo getJobs(String userQuery,
                        String count,
                        String stateQuery,
                        String queueQuery,
                        String startedBegin,
                        String startedEnd,
                        String finishBegin,
                        String finishEnd)

getJob

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

getJobAttempts

public AMAttemptsInfo getJobAttempts(String jid)

getJobCounters

public org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobCounterInfo getJobCounters(@Context
                                                                                   javax.servlet.http.HttpServletRequest hsr,
                                                                                   String jid)

getJobConf

public org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfInfo getJobConf(@Context
                                                                         javax.servlet.http.HttpServletRequest hsr,
                                                                         String jid)

getJobTasks

public org.apache.hadoop.mapreduce.v2.app.webapp.dao.TasksInfo getJobTasks(@Context
                                                                           javax.servlet.http.HttpServletRequest hsr,
                                                                           String jid,
                                                                           String type)

getJobTask

public org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo getJobTask(@Context
                                                                         javax.servlet.http.HttpServletRequest hsr,
                                                                         String jid,
                                                                         String tid)

getSingleTaskCounters

public org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskCounterInfo getSingleTaskCounters(@Context
                                                                                              javax.servlet.http.HttpServletRequest hsr,
                                                                                              String jid,
                                                                                              String tid)

getJobTaskAttempts

public org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptsInfo getJobTaskAttempts(@Context
                                                                                         javax.servlet.http.HttpServletRequest hsr,
                                                                                         String jid,
                                                                                         String tid)

getJobTaskAttemptId

public org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo getJobTaskAttemptId(@Context
                                                                                         javax.servlet.http.HttpServletRequest hsr,
                                                                                         String jid,
                                                                                         String tid,
                                                                                         String attId)

getJobTaskAttemptIdCounters

public org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptCounterInfo getJobTaskAttemptIdCounters(@Context
                                                                                                           javax.servlet.http.HttpServletRequest hsr,
                                                                                                           String jid,
                                                                                                           String tid,
                                                                                                           String attId)

getRemoteLogDirPath

public javax.ws.rs.core.Response getRemoteLogDirPath(@Context
                                                     javax.servlet.http.HttpServletRequest req,
                                                     String user,
                                                     String appIdStr)
                                              throws IOException

Returns the user qualified path name of the remote log directory for each pre-configured log aggregation file controller.

Parameters:

req - HttpServletRequest

Returns:

Path names grouped by file controller name

Throws:

IOException

getAggregatedLogsMeta

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public javax.ws.rs.core.Response getAggregatedLogsMeta(@Context
                                                                                                               javax.servlet.http.HttpServletRequest hsr,
                                                                                                               String fileName,
                                                                                                               Set<String> fileSize,
                                                                                                               Set<String> modificationTime,
                                                                                                               String appIdStr,
                                                                                                               String containerIdStr,
                                                                                                               String nmId)
                                                                                                        throws IOException

Throws:

IOException

getAggregatedLogsMeta

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public javax.ws.rs.core.Response getAggregatedLogsMeta(@Context
                                                                                                               javax.servlet.http.HttpServletRequest hsr,
                                                                                                               String appIdStr,
                                                                                                               String appAttemptIdStr,
                                                                                                               String containerIdStr,
                                                                                                               String nmId,
                                                                                                               boolean redirectedFromNode,
                                                                                                               boolean manualRedirection)

getContainerLogs

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public javax.ws.rs.core.Response getContainerLogs(@Context
                                                                                                          javax.servlet.http.HttpServletRequest hsr,
                                                                                                          String containerIdStr,
                                                                                                          String nmId,
                                                                                                          boolean redirectedFromNode,
                                                                                                          boolean manualRedirection)

getContainerLogFile

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public javax.ws.rs.core.Response getContainerLogFile(@Context
                                                                                                             javax.servlet.http.HttpServletRequest req,
                                                                                                             String containerIdStr,
                                                                                                             String filename,
                                                                                                             String format,
                                                                                                             String size,
                                                                                                             String nmId,
                                                                                                             boolean redirectedFromNode,
                                                                                                             boolean manualRedirection)