Package org.apache.hadoop.yarn.server.webapp

Class LogWebServiceUtils

java.lang.Object

org.apache.hadoop.yarn.server.webapp.LogWebServiceUtils

@Private
@Evolving
public final class LogWebServiceUtils
extends Object

Log web service utils class.

Method Summary

Modifier and Type	Method	Description
static javax.ws.rs.core.Response	createBadResponse(javax.ws.rs.core.Response.Status status, String errMessage)
static String	getAbsoluteNMWebAddress(org.apache.hadoop.conf.Configuration yarnConf, String nmWebAddress)
static String	getNMWebAddressFromRM(org.apache.hadoop.conf.Configuration yarnConf, String nodeId)
static String	getNoRedirectWarning()
protected static org.apache.hadoop.security.UserGroupInformation	getUser(javax.servlet.http.HttpServletRequest req)
static boolean	isRunningState(org.apache.hadoop.yarn.api.records.YarnApplicationState appState)
static long	parseLongParam(String bytes)
static void	rewrapAndThrowException(Exception e)
static void	rewrapAndThrowThrowable(Throwable t)
static javax.ws.rs.core.Response	sendStreamOutputResponse(org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileControllerFactory factory, org.apache.hadoop.yarn.api.records.ApplicationId appId, String appOwner, String nodeId, String containerIdStr, String fileName, String format, long bytes, boolean printEmptyLocalContainerLog)

Methods inherited from class java.lang.Object

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

Method Details

sendStreamOutputResponse

public static javax.ws.rs.core.Response sendStreamOutputResponse(org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileControllerFactory factory,
 org.apache.hadoop.yarn.api.records.ApplicationId appId,
 String appOwner,
 String nodeId,
 String containerIdStr,
 String fileName,
 String format,
 long bytes,
 boolean printEmptyLocalContainerLog)

getNoRedirectWarning

public static String getNoRedirectWarning()

rewrapAndThrowException

public static void rewrapAndThrowException(Exception e)

rewrapAndThrowThrowable

public static void rewrapAndThrowThrowable(Throwable t)

parseLongParam

public static long parseLongParam(String bytes)

createBadResponse

public static javax.ws.rs.core.Response createBadResponse(javax.ws.rs.core.Response.Status status,
 String errMessage)

isRunningState

public static boolean isRunningState(org.apache.hadoop.yarn.api.records.YarnApplicationState appState)

getUser

protected static org.apache.hadoop.security.UserGroupInformation getUser(javax.servlet.http.HttpServletRequest req)

getNMWebAddressFromRM

public static String getNMWebAddressFromRM(org.apache.hadoop.conf.Configuration yarnConf,
 String nodeId)
                                    throws org.codehaus.jettison.json.JSONException

Throws:

org.codehaus.jettison.json.JSONException

getAbsoluteNMWebAddress

public static String getAbsoluteNMWebAddress(org.apache.hadoop.conf.Configuration yarnConf,
 String nmWebAddress)