org.apache.hadoop.yarn.server.resourcemanager
Class ClientRMService

java.lang.Object
  extended by org.apache.hadoop.service.AbstractService
      extended by org.apache.hadoop.yarn.server.resourcemanager.ClientRMService
All Implemented Interfaces:
Closeable, org.apache.hadoop.service.Service, 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
protected  RMDelegationTokenSecretManager rmDTSecretManager
           
 
Constructor Summary
ClientRMService(RMContext rmContext, YarnScheduler scheduler, RMAppManager rmAppManager, org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager, QueueACLsManager queueACLsManager, RMDelegationTokenSecretManager rmDTSecretManager)
           
 
Method Summary
 org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse cancelDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest request)
           
 org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse forceKillApplication(org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest 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)
           
 InetSocketAddress getBindAddress()
           
 org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse getClusterMetrics(org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest request)
           
 org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse getClusterNodes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest request)
           
 org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenResponse getDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest request)
           
 org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse getNewApplication(org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest 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.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()
           
 org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest 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 Detail

rmDTSecretManager

protected RMDelegationTokenSecretManager rmDTSecretManager
Constructor Detail

ClientRMService

public ClientRMService(RMContext rmContext,
                       YarnScheduler scheduler,
                       RMAppManager rmAppManager,
                       org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager,
                       QueueACLsManager queueACLsManager,
                       RMDelegationTokenSecretManager rmDTSecretManager)
Method Detail

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

@InterfaceAudience.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.ApplicationClientProtocol
Throws:
org.apache.hadoop.yarn.exceptions.YarnException

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
Specified by:
submitApplication 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
Specified by:
getApplications in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
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.ApplicationClientProtocol
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.ApplicationClientProtocol
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.ApplicationClientProtocol
Throws:
org.apache.hadoop.yarn.exceptions.YarnException


Copyright © 2014 Apache Software Foundation. All Rights Reserved.