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, 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 classes/interfaces inherited from interface org.apache.hadoop.service.Service |
org.apache.hadoop.service.Service.STATE |
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 |
rmDTSecretManager
protected RMDelegationTokenSecretManager rmDTSecretManager
ClientRMService
public ClientRMService(RMContext rmContext,
YarnScheduler scheduler,
RMAppManager rmAppManager,
org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager,
QueueACLsManager queueACLsManager,
RMDelegationTokenSecretManager rmDTSecretManager)
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.