Package org.apache.hadoop.yarn.server.resourcemanager

Class ClientRMService

java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.server.resourcemanager.ClientRMService
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.service.Service, org.apache.hadoop.yarn.api.ApplicationBaseProtocol, org.apache.hadoop.yarn.api.ApplicationClientProtocol
public class ClientRMService extends org.apache.hadoop.service.AbstractService implements org.apache.hadoop.yarn.api.ApplicationClientProtocol
The client interface to the Resource Manager. This module handles all the rpc interfaces to the resource manager from the client.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

    org.apache.hadoop.service.Service.STATE

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected RMDelegationTokenSecretManager
    rmDTSecretManager
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ClientRMService(RMContext rmContext, YarnScheduler scheduler, RMAppManager rmAppManager, org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager, QueueACLsManager queueACLsManager, RMDelegationTokenSecretManager rmDTSecretManager)
     
    ClientRMService(RMContext rmContext, YarnScheduler scheduler, RMAppManager rmAppManager, org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager, QueueACLsManager queueACLsManager, RMDelegationTokenSecretManager rmDTSecretManager, org.apache.hadoop.yarn.util.Clock clock)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse
    cancelDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteResponse
    deleteReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.FailApplicationAttemptResponse
    failApplicationAttempt(org.apache.hadoop.yarn.api.protocolrecords.FailApplicationAttemptRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse
    forceKillApplication(org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportResponse
    getApplicationAttemptReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsResponse
    getApplicationAttempts(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportResponse
    getApplicationReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest request)
    It gives response which includes application report if the application present otherwise throws ApplicationNotFoundException.
    org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse
    getApplications(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest request)
    Get applications matching the GetApplicationsRequest.
    org.apache.hadoop.yarn.api.protocolrecords.GetAttributesToNodesResponse
    getAttributesToNodes(org.apache.hadoop.yarn.api.protocolrecords.GetAttributesToNodesRequest request)
     
    InetSocketAddress
    getBindAddress()
     
    org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse
    getClusterMetrics(org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeAttributesResponse
    getClusterNodeAttributes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeAttributesRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse
    getClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse
    getClusterNodes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse
    getContainerReport(org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetContainersResponse
    getContainers(org.apache.hadoop.yarn.api.protocolrecords.GetContainersRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenResponse
    getDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesResponse
    getLabelsToNodes(org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse
    getNewApplication(org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationResponse
    getNewReservation(org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetNodesToAttributesResponse
    getNodesToAttributes(org.apache.hadoop.yarn.api.protocolrecords.GetNodesToAttributesRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse
    getNodeToLabels(org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse
    getQueueInfo(org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse
    getQueueUserAcls(org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileResponse
    getResourceProfile(org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesResponse
    getResourceProfiles(org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoResponse
    getResourceTypeInfo(org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoRequest request)
     
    org.apache.hadoop.ipc.Server
    getServer()
     
    org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse
    listReservations(org.apache.hadoop.yarn.api.protocolrecords.ReservationListRequest requestInfo)
     
    org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesResponse
    moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenResponse
    renewDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenRequest request)
     
    protected void
    serviceInit(org.apache.hadoop.conf.Configuration conf)
     
    protected void
    serviceStart()
     
    protected void
    serviceStop()
     
    void
    setDisplayPerUserApps(boolean displayPerUserApps)
     
    org.apache.hadoop.yarn.api.protocolrecords.SignalContainerResponse
    signalToContainer(org.apache.hadoop.yarn.api.protocolrecords.SignalContainerRequest request)
    Send a signal to a container.
    org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse
    submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionResponse
    submitReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationPriorityResponse
    updateApplicationPriority(org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationPriorityRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationTimeoutsResponse
    updateApplicationTimeouts(org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationTimeoutsRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse
    updateReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateRequest request)
     

    Methods inherited from class org.apache.hadoop.service.AbstractService

    close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

  • Method Details

    • serviceInit

      protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
      Overrides:
      serviceInit in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • serviceStart

      protected void serviceStart() throws Exception
      Overrides:
      serviceStart in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • serviceStop

      protected void serviceStop() throws Exception
      Overrides:
      serviceStop in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • getBindAddress

      @Private public InetSocketAddress getBindAddress()

    • getNewApplication

      public org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse getNewApplication(org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      getNewApplication in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • getApplicationReport

      public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportResponse getApplicationReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      It gives response which includes application report if the application present otherwise throws ApplicationNotFoundException.
      Specified by:
      getApplicationReport in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • getApplicationAttemptReport

      public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportResponse getApplicationAttemptReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getApplicationAttemptReport in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getApplicationAttempts

      public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsResponse getApplicationAttempts(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getApplicationAttempts in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getContainerReport

      public org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse getContainerReport(org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getContainerReport in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getContainers

      public org.apache.hadoop.yarn.api.protocolrecords.GetContainersResponse getContainers(org.apache.hadoop.yarn.api.protocolrecords.GetContainersRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getContainers in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • submitApplication

      public org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      submitApplication in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • failApplicationAttempt

      public org.apache.hadoop.yarn.api.protocolrecords.FailApplicationAttemptResponse failApplicationAttempt(org.apache.hadoop.yarn.api.protocolrecords.FailApplicationAttemptRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      failApplicationAttempt in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • forceKillApplication

      public org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse forceKillApplication(org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      forceKillApplication in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • getClusterMetrics

      public org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse getClusterMetrics(org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      getClusterMetrics in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • getApplications

      public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse getApplications(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Get applications matching the GetApplicationsRequest. If caseSensitive is set to false, applicationTypes in GetApplicationRequest are expected to be in all-lowercase
      Specified by:
      getApplications in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • getClusterNodes

      public org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse getClusterNodes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      getClusterNodes in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • getQueueInfo

      public org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse getQueueInfo(org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      getQueueInfo in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • getQueueUserAcls

      public org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse getQueueUserAcls(org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      getQueueUserAcls in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • getDelegationToken

      public org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenResponse getDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      getDelegationToken in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • renewDelegationToken

      public org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenResponse renewDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      renewDelegationToken in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • cancelDelegationToken

      public org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse cancelDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      cancelDelegationToken in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • moveApplicationAcrossQueues

      public org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      moveApplicationAcrossQueues in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException

    • getServer

      @VisibleForTesting public org.apache.hadoop.ipc.Server getServer()

    • getNewReservation

      public org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationResponse getNewReservation(org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getNewReservation in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • submitReservation

      public org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionResponse submitReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      submitReservation in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • updateReservation

      public org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse updateReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      updateReservation in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • deleteReservation

      public org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteResponse deleteReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      deleteReservation in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • listReservations

      public org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse listReservations(org.apache.hadoop.yarn.api.protocolrecords.ReservationListRequest requestInfo) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      listReservations in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getNodeToLabels

      public org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse getNodeToLabels(org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getNodeToLabels in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getLabelsToNodes

      public org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesResponse getLabelsToNodes(org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getLabelsToNodes in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getClusterNodeLabels

      public org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse getClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getClusterNodeLabels in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • updateApplicationPriority

      public org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationPriorityResponse updateApplicationPriority(org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationPriorityRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      updateApplicationPriority in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • signalToContainer

      public org.apache.hadoop.yarn.api.protocolrecords.SignalContainerResponse signalToContainer(org.apache.hadoop.yarn.api.protocolrecords.SignalContainerRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Send a signal to a container. After the request passes some sanity check, it will be delivered to RMNodeImpl so that the next NM heartbeat will pick up the signal request
      Specified by:
      signalToContainer in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Parameters:
      request - request to signal a container
      Returns:
      the response of sending signal request
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException - rpc related exception
      IOException - fail to obtain user group information

    • updateApplicationTimeouts

      public org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationTimeoutsResponse updateApplicationTimeouts(org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationTimeoutsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      updateApplicationTimeouts in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getResourceProfiles

      public org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesResponse getResourceProfiles(org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getResourceProfiles in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getResourceProfile

      public org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileResponse getResourceProfile(org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getResourceProfile in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getResourceTypeInfo

      public org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoResponse getResourceTypeInfo(org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getResourceTypeInfo in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getAttributesToNodes

      public org.apache.hadoop.yarn.api.protocolrecords.GetAttributesToNodesResponse getAttributesToNodes(org.apache.hadoop.yarn.api.protocolrecords.GetAttributesToNodesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getAttributesToNodes in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getClusterNodeAttributes

      public org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeAttributesResponse getClusterNodeAttributes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeAttributesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getClusterNodeAttributes in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getNodesToAttributes

      public org.apache.hadoop.yarn.api.protocolrecords.GetNodesToAttributesResponse getNodesToAttributes(org.apache.hadoop.yarn.api.protocolrecords.GetNodesToAttributesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getNodesToAttributes in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • setDisplayPerUserApps

      @VisibleForTesting public void setDisplayPerUserApps(boolean displayPerUserApps)