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

Class DefaultRequestInterceptorREST

java.lang.Object
org.apache.hadoop.yarn.server.router.webapp.AbstractRESTRequestInterceptor
org.apache.hadoop.yarn.server.router.webapp.DefaultRequestInterceptorREST
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable, org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServiceProtocol, RESTRequestInterceptor
public class DefaultRequestInterceptorREST extends AbstractRESTRequestInterceptor
Extends the AbstractRequestInterceptorClient class and provides an implementation that simply forwards the client requests to the resource manager.

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultRequestInterceptorREST()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    javax.ws.rs.core.Response
    addToClusterNodeLabels(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelsInfo newNodeLabels, javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    cancelDelegationToken(javax.servlet.http.HttpServletRequest hsr)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.RMQueueAclInfo
    checkUserAccessToQueue(String queue, String username, String queueAclType, javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    createNewApplication(javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    createNewReservation(javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    deleteReservation(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationDeleteRequestInfo resContext, javax.servlet.http.HttpServletRequest hsr)
     
    String
    dumpSchedulerLogs(String time, javax.servlet.http.HttpServletRequest hsr)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ClusterInfo
    get()
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ActivitiesInfo
    getActivities(javax.servlet.http.HttpServletRequest hsr, String nodeId, String groupBy)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppInfo
    getApp(javax.servlet.http.HttpServletRequest hsr, String appId, Set<String> unselectedFields)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppActivitiesInfo
    getAppActivities(javax.servlet.http.HttpServletRequest hsr, String appId, String time, Set<String> requestPriorities, Set<String> allocationRequestIds, String groupBy, String limit, Set<String> actions, boolean summarize)
     
    org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo
    getAppAttempt(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res, String appId, String appAttemptId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppAttemptsInfo
    getAppAttempts(javax.servlet.http.HttpServletRequest hsr, String appId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppPriority
    getAppPriority(javax.servlet.http.HttpServletRequest hsr, String appId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppQueue
    getAppQueue(javax.servlet.http.HttpServletRequest hsr, String appId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppsInfo
    getApps(javax.servlet.http.HttpServletRequest hsr, String stateQuery, Set<String> statesQuery, String finalStatusQuery, String userQuery, String queueQuery, String count, String startedBegin, String startedEnd, String finishBegin, String finishEnd, Set<String> applicationTypes, Set<String> applicationTags, String name, Set<String> unselectedFields)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppState
    getAppState(javax.servlet.http.HttpServletRequest hsr, String appId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ApplicationStatisticsInfo
    getAppStatistics(javax.servlet.http.HttpServletRequest hsr, Set<String> stateQueries, Set<String> typeQueries)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppTimeoutInfo
    getAppTimeout(javax.servlet.http.HttpServletRequest hsr, String appId, String type)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppTimeoutsInfo
    getAppTimeouts(javax.servlet.http.HttpServletRequest hsr, String appId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.BulkActivitiesInfo
    getBulkActivities(javax.servlet.http.HttpServletRequest hsr, String groupBy, int activitiesCount)
     
    javax.ws.rs.client.Client
    getClient()
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ClusterInfo
    getClusterInfo()
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ClusterMetricsInfo
    getClusterMetricsInfo()
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelsInfo
    getClusterNodeLabels(javax.servlet.http.HttpServletRequest hsr)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ClusterUserInfo
    getClusterUserInfo(javax.servlet.http.HttpServletRequest hsr)
     
    org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo
    getContainer(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res, String appId, String appAttemptId, String containerId)
     
    org.apache.hadoop.yarn.server.webapp.dao.ContainersInfo
    getContainers(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res, String appId, String appAttemptId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelsInfo
    getLabelsOnNode(javax.servlet.http.HttpServletRequest hsr, String nodeId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.LabelsToNodesInfo
    getLabelsToNodes(Set<String> labels)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeInfo
    getNode(String nodeId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodesInfo
    getNodes(String states)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeToLabelsInfo
    getNodeToLabels(javax.servlet.http.HttpServletRequest hsr)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelsInfo
    getRMNodeLabels(javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    getSchedulerConfiguration(javax.servlet.http.HttpServletRequest req)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.SchedulerTypeInfo
    getSchedulerInfo()
     
    protected org.apache.hadoop.yarn.server.federation.store.records.SubClusterId
    getSubClusterId()
     
    protected String
    getWebAppAddress()
     
    void
    init(String user)
    Initializes the RESTRequestInterceptor.
    javax.ws.rs.core.Response
    listReservation(String queue, String reservationId, long startTime, long endTime, boolean includeResourceAllocations, javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    postDelegationToken(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.DelegationToken tokenData, javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    postDelegationTokenExpiration(javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    removeFromClusterNodeLabels(Set<String> oldNodeLabels, javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    replaceLabelsOnNode(Set<String> newNodeLabelsName, javax.servlet.http.HttpServletRequest hsr, String nodeId)
     
    javax.ws.rs.core.Response
    replaceLabelsOnNodes(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeToLabelsEntryList newNodeToLabels, javax.servlet.http.HttpServletRequest hsr)
     
    void
    setNextInterceptor(RESTRequestInterceptor next)
    Sets the RESTRequestInterceptor in the chain.
    protected void
    setSubClusterId(org.apache.hadoop.yarn.server.federation.store.records.SubClusterId scId)
     
    void
    setWebAppAddress(String webAppAddress)
     
    javax.ws.rs.core.Response
    signalToContainer(String containerId, String command, javax.servlet.http.HttpServletRequest req)
     
    javax.ws.rs.core.Response
    submitApplication(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ApplicationSubmissionContextInfo newApp, javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    submitReservation(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationSubmissionRequestInfo resContext, javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    updateApplicationPriority(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppPriority targetPriority, javax.servlet.http.HttpServletRequest hsr, String appId)
     
    javax.ws.rs.core.Response
    updateApplicationTimeout(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppTimeoutInfo appTimeout, javax.servlet.http.HttpServletRequest hsr, String appId)
     
    javax.ws.rs.core.Response
    updateAppQueue(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppQueue targetQueue, javax.servlet.http.HttpServletRequest hsr, String appId)
     
    javax.ws.rs.core.Response
    updateAppState(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppState targetState, javax.servlet.http.HttpServletRequest hsr, String appId)
     
    org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ResourceInfo
    updateNodeResource(javax.servlet.http.HttpServletRequest hsr, String nodeId, org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ResourceOptionInfo resourceOption)
     
    javax.ws.rs.core.Response
    updateReservation(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationUpdateRequestInfo resContext, javax.servlet.http.HttpServletRequest hsr)
     
    javax.ws.rs.core.Response
    updateSchedulerConfiguration(org.apache.hadoop.yarn.webapp.dao.SchedConfUpdateInfo mutationInfo, javax.servlet.http.HttpServletRequest req)
     

    Methods inherited from class org.apache.hadoop.yarn.server.router.webapp.AbstractRESTRequestInterceptor

    getConf, getNextInterceptor, getRouterClientRMService, getUser, setConf, setRouterClientRMService, shutdown

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • DefaultRequestInterceptorREST

      public DefaultRequestInterceptorREST()

  • Method Details

    • setWebAppAddress

      public void setWebAppAddress(String webAppAddress)

    • getWebAppAddress

      protected String getWebAppAddress()

    • setSubClusterId

      protected void setSubClusterId(org.apache.hadoop.yarn.server.federation.store.records.SubClusterId scId)

    • getSubClusterId

      protected org.apache.hadoop.yarn.server.federation.store.records.SubClusterId getSubClusterId()

    • init

      public void init(String user)
      Description copied from class: AbstractRESTRequestInterceptor
      Initializes the RESTRequestInterceptor.
      Specified by:
      init in interface RESTRequestInterceptor
      Overrides:
      init in class AbstractRESTRequestInterceptor
      Parameters:
      user - the name of the client

    • get

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ClusterInfo get()

    • getClusterInfo

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ClusterInfo getClusterInfo()

    • getClusterUserInfo

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ClusterUserInfo getClusterUserInfo(javax.servlet.http.HttpServletRequest hsr)

    • getClusterMetricsInfo

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ClusterMetricsInfo getClusterMetricsInfo()

    • getSchedulerInfo

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.SchedulerTypeInfo getSchedulerInfo()

    • dumpSchedulerLogs

      public String dumpSchedulerLogs(String time, javax.servlet.http.HttpServletRequest hsr) throws IOException
      Throws:
      IOException

    • getNodes

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodesInfo getNodes(String states)

    • getNode

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeInfo getNode(String nodeId)

    • updateNodeResource

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ResourceInfo updateNodeResource(javax.servlet.http.HttpServletRequest hsr, String nodeId, org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ResourceOptionInfo resourceOption)

    • getApps

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppsInfo getApps(javax.servlet.http.HttpServletRequest hsr, String stateQuery, Set<String> statesQuery, String finalStatusQuery, String userQuery, String queueQuery, String count, String startedBegin, String startedEnd, String finishBegin, String finishEnd, Set<String> applicationTypes, Set<String> applicationTags, String name, Set<String> unselectedFields)

    • getActivities

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ActivitiesInfo getActivities(javax.servlet.http.HttpServletRequest hsr, String nodeId, String groupBy)

    • getBulkActivities

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.BulkActivitiesInfo getBulkActivities(javax.servlet.http.HttpServletRequest hsr, String groupBy, int activitiesCount)

    • getAppActivities

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppActivitiesInfo getAppActivities(javax.servlet.http.HttpServletRequest hsr, String appId, String time, Set<String> requestPriorities, Set<String> allocationRequestIds, String groupBy, String limit, Set<String> actions, boolean summarize)

    • getAppStatistics

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ApplicationStatisticsInfo getAppStatistics(javax.servlet.http.HttpServletRequest hsr, Set<String> stateQueries, Set<String> typeQueries)

    • getApp

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppInfo getApp(javax.servlet.http.HttpServletRequest hsr, String appId, Set<String> unselectedFields)

    • getAppState

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppState getAppState(javax.servlet.http.HttpServletRequest hsr, String appId) throws org.apache.hadoop.security.authorize.AuthorizationException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException

    • updateAppState

      public javax.ws.rs.core.Response updateAppState(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppState targetState, javax.servlet.http.HttpServletRequest hsr, String appId) throws org.apache.hadoop.security.authorize.AuthorizationException, org.apache.hadoop.yarn.exceptions.YarnException, InterruptedException, IOException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      org.apache.hadoop.yarn.exceptions.YarnException
      InterruptedException
      IOException

    • getNodeToLabels

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeToLabelsInfo getNodeToLabels(javax.servlet.http.HttpServletRequest hsr) throws IOException
      Throws:
      IOException

    • getLabelsToNodes

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.LabelsToNodesInfo getLabelsToNodes(Set<String> labels) throws IOException
      Throws:
      IOException

    • replaceLabelsOnNodes

      public javax.ws.rs.core.Response replaceLabelsOnNodes(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeToLabelsEntryList newNodeToLabels, javax.servlet.http.HttpServletRequest hsr) throws IOException
      Throws:
      IOException

    • replaceLabelsOnNode

      public javax.ws.rs.core.Response replaceLabelsOnNode(Set<String> newNodeLabelsName, javax.servlet.http.HttpServletRequest hsr, String nodeId) throws Exception
      Throws:
      Exception

    • getClusterNodeLabels

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelsInfo getClusterNodeLabels(javax.servlet.http.HttpServletRequest hsr) throws IOException
      Throws:
      IOException

    • addToClusterNodeLabels

      public javax.ws.rs.core.Response addToClusterNodeLabels(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelsInfo newNodeLabels, javax.servlet.http.HttpServletRequest hsr) throws Exception
      Throws:
      Exception

    • removeFromClusterNodeLabels

      public javax.ws.rs.core.Response removeFromClusterNodeLabels(Set<String> oldNodeLabels, javax.servlet.http.HttpServletRequest hsr) throws Exception
      Throws:
      Exception

    • getLabelsOnNode

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelsInfo getLabelsOnNode(javax.servlet.http.HttpServletRequest hsr, String nodeId) throws IOException
      Throws:
      IOException

    • getAppPriority

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppPriority getAppPriority(javax.servlet.http.HttpServletRequest hsr, String appId) throws org.apache.hadoop.security.authorize.AuthorizationException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException

    • updateApplicationPriority

      public javax.ws.rs.core.Response updateApplicationPriority(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppPriority targetPriority, javax.servlet.http.HttpServletRequest hsr, String appId) throws org.apache.hadoop.security.authorize.AuthorizationException, org.apache.hadoop.yarn.exceptions.YarnException, InterruptedException, IOException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      org.apache.hadoop.yarn.exceptions.YarnException
      InterruptedException
      IOException

    • getAppQueue

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppQueue getAppQueue(javax.servlet.http.HttpServletRequest hsr, String appId) throws org.apache.hadoop.security.authorize.AuthorizationException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException

    • updateAppQueue

      public javax.ws.rs.core.Response updateAppQueue(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppQueue targetQueue, javax.servlet.http.HttpServletRequest hsr, String appId) throws org.apache.hadoop.security.authorize.AuthorizationException, org.apache.hadoop.yarn.exceptions.YarnException, InterruptedException, IOException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      org.apache.hadoop.yarn.exceptions.YarnException
      InterruptedException
      IOException

    • createNewApplication

      public javax.ws.rs.core.Response createNewApplication(javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException, IOException, InterruptedException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      IOException
      InterruptedException

    • submitApplication

      public javax.ws.rs.core.Response submitApplication(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ApplicationSubmissionContextInfo newApp, javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException, IOException, InterruptedException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      IOException
      InterruptedException

    • postDelegationToken

      public javax.ws.rs.core.Response postDelegationToken(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.DelegationToken tokenData, javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException, IOException, InterruptedException, Exception
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      IOException
      InterruptedException
      Exception

    • postDelegationTokenExpiration

      public javax.ws.rs.core.Response postDelegationTokenExpiration(javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException, IOException, InterruptedException, Exception
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      IOException
      InterruptedException
      Exception

    • cancelDelegationToken

      public javax.ws.rs.core.Response cancelDelegationToken(javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException, IOException, InterruptedException, Exception
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      IOException
      InterruptedException
      Exception

    • createNewReservation

      public javax.ws.rs.core.Response createNewReservation(javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException, IOException, InterruptedException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      IOException
      InterruptedException

    • submitReservation

      public javax.ws.rs.core.Response submitReservation(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationSubmissionRequestInfo resContext, javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException, IOException, InterruptedException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      IOException
      InterruptedException

    • updateReservation

      public javax.ws.rs.core.Response updateReservation(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationUpdateRequestInfo resContext, javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException, IOException, InterruptedException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      IOException
      InterruptedException

    • deleteReservation

      public javax.ws.rs.core.Response deleteReservation(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.ReservationDeleteRequestInfo resContext, javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException, IOException, InterruptedException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      IOException
      InterruptedException

    • listReservation

      public javax.ws.rs.core.Response listReservation(String queue, String reservationId, long startTime, long endTime, boolean includeResourceAllocations, javax.servlet.http.HttpServletRequest hsr) throws Exception
      Throws:
      Exception

    • getAppTimeout

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppTimeoutInfo getAppTimeout(javax.servlet.http.HttpServletRequest hsr, String appId, String type) throws org.apache.hadoop.security.authorize.AuthorizationException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException

    • getAppTimeouts

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppTimeoutsInfo getAppTimeouts(javax.servlet.http.HttpServletRequest hsr, String appId) throws org.apache.hadoop.security.authorize.AuthorizationException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException

    • updateApplicationTimeout

      public javax.ws.rs.core.Response updateApplicationTimeout(org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppTimeoutInfo appTimeout, javax.servlet.http.HttpServletRequest hsr, String appId) throws org.apache.hadoop.security.authorize.AuthorizationException, org.apache.hadoop.yarn.exceptions.YarnException, InterruptedException, IOException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      org.apache.hadoop.yarn.exceptions.YarnException
      InterruptedException
      IOException

    • getAppAttempts

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.AppAttemptsInfo getAppAttempts(javax.servlet.http.HttpServletRequest hsr, String appId)

    • checkUserAccessToQueue

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.RMQueueAclInfo checkUserAccessToQueue(String queue, String username, String queueAclType, javax.servlet.http.HttpServletRequest hsr) throws org.apache.hadoop.security.authorize.AuthorizationException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException

    • getAppAttempt

      public org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo getAppAttempt(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res, String appId, String appAttemptId)
      Parameters:
      req - the servlet request
      res - the servlet response
      appId - the application we want to get the appAttempt. It is a PathParam.
      appAttemptId - the AppAttempt we want to get the info. It is a PathParam.
      Returns:
      AppAttemptInfo of the specific AppAttempt
      See Also:
      • WebServices.getAppAttempt(HttpServletRequest, HttpServletResponse, String, String)

    • getContainers

      public org.apache.hadoop.yarn.server.webapp.dao.ContainersInfo getContainers(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res, String appId, String appAttemptId)
      Parameters:
      req - the servlet request
      res - the servlet response
      appId - the application we want to get the containers info. It is a PathParam.
      appAttemptId - the AppAttempt we want to get the info. It is a PathParam.
      Returns:
      ContainersInfo of all the containers that belong to the specific AppAttempt
      See Also:
      • WebServices.getContainers(HttpServletRequest, HttpServletResponse, String, String)

    • getContainer

      public org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo getContainer(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res, String appId, String appAttemptId, String containerId)
      Parameters:
      req - the servlet request
      res - the servlet response
      appId - the application we want to get the containers info. It is a PathParam.
      appAttemptId - the AppAttempt we want to get the info. It is a PathParam.
      containerId - the container we want to get the info. It is a PathParam.
      Returns:
      ContainerInfo of the specific ContainerId
      See Also:
      • WebServices.getContainer(HttpServletRequest, HttpServletResponse, String, String, String)

    • updateSchedulerConfiguration

      public javax.ws.rs.core.Response updateSchedulerConfiguration(org.apache.hadoop.yarn.webapp.dao.SchedConfUpdateInfo mutationInfo, javax.servlet.http.HttpServletRequest req) throws org.apache.hadoop.security.authorize.AuthorizationException, InterruptedException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException
      InterruptedException

    • getSchedulerConfiguration

      public javax.ws.rs.core.Response getSchedulerConfiguration(javax.servlet.http.HttpServletRequest req) throws org.apache.hadoop.security.authorize.AuthorizationException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException

    • setNextInterceptor

      public void setNextInterceptor(RESTRequestInterceptor next)
      Description copied from class: AbstractRESTRequestInterceptor
      Sets the RESTRequestInterceptor in the chain.
      Specified by:
      setNextInterceptor in interface RESTRequestInterceptor
      Overrides:
      setNextInterceptor in class AbstractRESTRequestInterceptor
      Parameters:
      next - the RESTRequestInterceptor to set in the pipeline

    • signalToContainer

      public javax.ws.rs.core.Response signalToContainer(String containerId, String command, javax.servlet.http.HttpServletRequest req) throws org.apache.hadoop.security.authorize.AuthorizationException
      Throws:
      org.apache.hadoop.security.authorize.AuthorizationException

    • getClient

      @VisibleForTesting public javax.ws.rs.client.Client getClient()

    • getRMNodeLabels

      public org.apache.hadoop.yarn.server.resourcemanager.webapp.dao.NodeLabelsInfo getRMNodeLabels(javax.servlet.http.HttpServletRequest hsr)