public class ClientRMService
extends org.apache.hadoop.service.AbstractService
implements org.apache.hadoop.yarn.api.ApplicationClientProtocol
Modifier and Type | Field and Description |
---|---|
protected RMDelegationTokenSecretManager |
rmDTSecretManager |
Constructor and 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) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.api.protocolrecords.AddDebugAppResponse |
addDebugApp(org.apache.hadoop.yarn.api.protocolrecords.AddDebugAppRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.AddDebugQueueResponse |
addDebugQueue(org.apache.hadoop.yarn.api.protocolrecords.AddDebugQueueRequest request) |
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.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) |
org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse |
getApplications(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest request,
boolean caseSensitive)
Get applications matching the
GetApplicationsRequest . |
InetSocketAddress |
getBindAddress() |
org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse |
getClusterMetrics(org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse |
getClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.NoOpGetClusterNodeLabelsResponse |
getClusterNodeLabelsNoOp(org.apache.hadoop.yarn.api.protocolrecords.NoOpGetClusterNodeLabelsRequest 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.GetDebugAppsResponse |
getDebugApps(org.apache.hadoop.yarn.api.protocolrecords.GetDebugAppsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetDebugQueuesResponse |
getDebugQueues(org.apache.hadoop.yarn.api.protocolrecords.GetDebugQueuesRequest 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.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.ipc.Server |
getServer() |
org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesResponse |
moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.RefreshClusterNodeLabelsResponse |
refreshClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.RefreshClusterNodeLabelsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.RemoveDebugAppResponse |
removeDebugApp(org.apache.hadoop.yarn.api.protocolrecords.RemoveDebugAppRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.RemoveDebugQueueResponse |
removeDebugQueue(org.apache.hadoop.yarn.api.protocolrecords.RemoveDebugQueueRequest 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) |
org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionResponse |
submitReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse |
updateReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateRequest request) |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
protected RMDelegationTokenSecretManager rmDTSecretManager
public ClientRMService(RMContext rmContext, YarnScheduler scheduler, RMAppManager rmAppManager, org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager, QueueACLsManager queueACLsManager, RMDelegationTokenSecretManager rmDTSecretManager)
public 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)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
@InterfaceAudience.Private public InetSocketAddress getBindAddress()
public org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse getNewApplication(org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
getNewApplication
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportResponse getApplicationReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
getApplicationReport
in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
org.apache.hadoop.yarn.exceptions.YarnException
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
getApplicationAttemptReport
in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
getApplicationAttempts
in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
getContainerReport
in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
getContainers
in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
submitApplication
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse forceKillApplication(org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
forceKillApplication
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse getClusterMetrics(org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
getClusterMetrics
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse getApplications(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
getApplications
in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
org.apache.hadoop.yarn.exceptions.YarnException
@InterfaceAudience.Private public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse getApplications(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest request, boolean caseSensitive) throws org.apache.hadoop.yarn.exceptions.YarnException
GetApplicationsRequest
. If
caseSensitive is set to false, applicationTypes in
GetApplicationRequest are expected to be in all-lowercaseorg.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse getClusterNodes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
getClusterNodes
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse getQueueInfo(org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
getQueueInfo
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse getQueueUserAcls(org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
getQueueUserAcls
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenResponse getDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
getDelegationToken
in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenResponse renewDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
renewDelegationToken
in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse cancelDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
cancelDelegationToken
in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol
org.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException
moveApplicationAcrossQueues
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
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
getClusterNodeLabels
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.RefreshClusterNodeLabelsResponse refreshClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.RefreshClusterNodeLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
refreshClusterNodeLabels
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.ipc.Server getServer()
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
submitReservation
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
updateReservation
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
deleteReservation
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
getNodeToLabels
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
getLabelsToNodes
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.NoOpGetClusterNodeLabelsResponse getClusterNodeLabelsNoOp(org.apache.hadoop.yarn.api.protocolrecords.NoOpGetClusterNodeLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getClusterNodeLabelsNoOp
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.AddDebugAppResponse addDebugApp(org.apache.hadoop.yarn.api.protocolrecords.AddDebugAppRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
addDebugApp
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.RemoveDebugAppResponse removeDebugApp(org.apache.hadoop.yarn.api.protocolrecords.RemoveDebugAppRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
removeDebugApp
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetDebugAppsResponse getDebugApps(org.apache.hadoop.yarn.api.protocolrecords.GetDebugAppsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getDebugApps
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.AddDebugQueueResponse addDebugQueue(org.apache.hadoop.yarn.api.protocolrecords.AddDebugQueueRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
addDebugQueue
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.RemoveDebugQueueResponse removeDebugQueue(org.apache.hadoop.yarn.api.protocolrecords.RemoveDebugQueueRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
removeDebugQueue
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetDebugQueuesResponse getDebugQueues(org.apache.hadoop.yarn.api.protocolrecords.GetDebugQueuesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getDebugQueues
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
Copyright © 2019 Apache Software Foundation. All Rights Reserved.