Modifier and Type | Method and Description |
---|---|
protected void |
RMCommunicator.doUnregistration() |
Modifier and Type | Method and Description |
---|---|
AllocateResponse |
ApplicationMasterProtocol.allocate(AllocateRequest request)
The main interface between an
ApplicationMaster and the
ResourceManager . |
CancelDelegationTokenResponse |
ApplicationClientProtocol.cancelDelegationToken(CancelDelegationTokenRequest request)
Cancel an existing delegation
Token . |
FinishApplicationMasterResponse |
ApplicationMasterProtocol.finishApplicationMaster(FinishApplicationMasterRequest request)
The interface used by an
ApplicationMaster to notify the
ResourceManager about its completion (success or failed). |
KillApplicationResponse |
ApplicationClientProtocol.forceKillApplication(KillApplicationRequest request)
The interface used by clients to request the
ResourceManager to abort submitted application. |
GetApplicationReportResponse |
ApplicationClientProtocol.getApplicationReport(GetApplicationReportRequest request)
The interface used by clients to get a report of an Application from
the
ResourceManager . |
GetApplicationsResponse |
ApplicationClientProtocol.getApplications(GetApplicationsRequest request)
The interface used by clients to get a report of Applications
matching the filters defined by
GetApplicationsRequest
in the cluster from the ResourceManager . |
GetClusterMetricsResponse |
ApplicationClientProtocol.getClusterMetrics(GetClusterMetricsRequest request)
The interface used by clients to get metrics about the cluster from
the
ResourceManager . |
GetClusterNodesResponse |
ApplicationClientProtocol.getClusterNodes(GetClusterNodesRequest request)
The interface used by clients to get a report of all nodes
in the cluster from the
ResourceManager . |
GetContainerStatusesResponse |
ContainerManagementProtocol.getContainerStatuses(GetContainerStatusesRequest request)
The API used by the
ApplicationMaster to request for current
statuses of Container s from the NodeManager . |
GetDelegationTokenResponse |
ApplicationClientProtocol.getDelegationToken(GetDelegationTokenRequest request)
The interface used by clients to get delegation token, enabling the
containers to be able to talk to the service using those tokens.
|
GetNewApplicationResponse |
ApplicationClientProtocol.getNewApplication(GetNewApplicationRequest request)
The interface used by clients to obtain a new
ApplicationId for
submitting new applications. |
GetQueueInfoResponse |
ApplicationClientProtocol.getQueueInfo(GetQueueInfoRequest request)
The interface used by clients to get information about queues
from the
ResourceManager . |
GetQueueUserAclsInfoResponse |
ApplicationClientProtocol.getQueueUserAcls(GetQueueUserAclsInfoRequest request)
The interface used by clients to get information about queue
acls for current user from the
ResourceManager . |
RegisterApplicationMasterResponse |
ApplicationMasterProtocol.registerApplicationMaster(RegisterApplicationMasterRequest request)
The interface used by a new
ApplicationMaster to register with
the ResourceManager . |
RenewDelegationTokenResponse |
ApplicationClientProtocol.renewDelegationToken(RenewDelegationTokenRequest request)
Renew an existing delegation
Token . |
StartContainersResponse |
ContainerManagementProtocol.startContainers(StartContainersRequest request)
The
ApplicationMaster provides a list of
StartContainerRequest s to a NodeManager to
start Container s allocated to it using this interface. |
StopContainersResponse |
ContainerManagementProtocol.stopContainers(StopContainersRequest request)
The
ApplicationMaster requests a NodeManager to
stop a list of Container s allocated to it using this
interface. |
SubmitApplicationResponse |
ApplicationClientProtocol.submitApplication(SubmitApplicationRequest request)
The interface used by clients to submit a new application to the
ResourceManager. |
Modifier and Type | Method and Description |
---|---|
boolean |
Client.run()
Main run function for the client
|
boolean |
ApplicationMaster.run()
Main run function for the application master
|
Modifier and Type | Method and Description |
---|---|
void |
UnmanagedAMLauncher.launchAM(ApplicationAttemptId attemptId) |
boolean |
UnmanagedAMLauncher.run() |
Modifier and Type | Method and Description |
---|---|
abstract AllocateResponse |
AMRMClient.allocate(float progressIndicator)
Request additional containers and receive new container allocations.
|
abstract YarnClientApplication |
YarnClient.createApplication()
Obtain a
YarnClientApplication for a new application,
which in turn contains the ApplicationSubmissionContext and
GetNewApplicationResponse
objects. |
abstract List<QueueInfo> |
YarnClient.getAllQueues()
Get information (
QueueInfo ) about all queues, recursively if there
is a hierarchy |
abstract Token<AMRMTokenIdentifier> |
YarnClient.getAMRMToken(ApplicationId appId)
Get the AMRM token of the application.
|
abstract ApplicationReport |
YarnClient.getApplicationReport(ApplicationId appId)
Get a report of the given Application.
|
abstract List<ApplicationReport> |
YarnClient.getApplications()
Get a report (ApplicationReport) of all Applications in the cluster.
|
abstract List<ApplicationReport> |
YarnClient.getApplications(EnumSet<YarnApplicationState> applicationStates)
Get a report (ApplicationReport) of Applications matching the given
application states in the cluster.
|
abstract List<ApplicationReport> |
YarnClient.getApplications(Set<String> applicationTypes)
Get a report (ApplicationReport) of Applications
matching the given application types in the cluster.
|
abstract List<ApplicationReport> |
YarnClient.getApplications(Set<String> applicationTypes,
EnumSet<YarnApplicationState> applicationStates)
Get a report (ApplicationReport) of Applications matching the given
application types and application states in the cluster.
|
abstract List<QueueInfo> |
YarnClient.getChildQueueInfos(String parent)
Get information (
QueueInfo ) about all the immediate children queues
of the given queue |
abstract ContainerStatus |
NMClient.getContainerStatus(ContainerId containerId,
NodeId nodeId)
Query the status of a container.
|
abstract List<NodeReport> |
YarnClient.getNodeReports(NodeState... states)
Get a report of nodes (
NodeReport ) in the cluster. |
abstract List<QueueUserACLInfo> |
YarnClient.getQueueAclsInfo()
Get information about acls for current user on all the
existing queues.
|
abstract QueueInfo |
YarnClient.getQueueInfo(String queueName)
Get information (
QueueInfo ) about a given queue. |
abstract Token |
YarnClient.getRMDelegationToken(Text renewer)
Get a delegation token so as to be able to talk to YARN using those tokens.
|
abstract List<QueueInfo> |
YarnClient.getRootQueueInfos()
Get information (
QueueInfo ) about top level queues. |
abstract YarnClusterMetrics |
YarnClient.getYarnClusterMetrics()
Get metrics (
YarnClusterMetrics ) about the cluster. |
abstract void |
YarnClient.killApplication(ApplicationId applicationId)
Kill an application identified by given ID.
|
abstract RegisterApplicationMasterResponse |
AMRMClient.registerApplicationMaster(String appHostName,
int appHostPort,
String appTrackingUrl)
Register the application master.
|
abstract Map<String,ByteBuffer> |
NMClient.startContainer(Container container,
ContainerLaunchContext containerLaunchContext)
Start an allocated container.
|
abstract void |
NMClient.stopContainer(ContainerId containerId,
NodeId nodeId)
Stop an started container.
|
abstract ApplicationId |
YarnClient.submitApplication(ApplicationSubmissionContext appContext)
Submit a new application to
YARN. It is a blocking call, such
that it will not return ApplicationId until the submitted
application has been submitted and accepted by the ResourceManager. |
abstract void |
AMRMClient.unregisterApplicationMaster(FinalApplicationStatus appStatus,
String appMessage,
String appTrackingUrl)
Unregister the application master.
|
Modifier and Type | Method and Description |
---|---|
abstract RegisterApplicationMasterResponse |
AMRMClientAsync.registerApplicationMaster(String appHostName,
int appHostPort,
String appTrackingUrl)
Registers this application master with the resource manager.
|
abstract void |
AMRMClientAsync.unregisterApplicationMaster(FinalApplicationStatus appStatus,
String appMessage,
String appTrackingUrl)
Unregister the application master.
|
Modifier and Type | Method and Description |
---|---|
RegisterApplicationMasterResponse |
AMRMClientAsyncImpl.registerApplicationMaster(String appHostName,
int appHostPort,
String appTrackingUrl)
Registers this application master with the resource manager.
|
void |
AMRMClientAsyncImpl.unregisterApplicationMaster(FinalApplicationStatus appStatus,
String appMessage,
String appTrackingUrl)
Unregister the application master.
|
Modifier and Type | Class and Description |
---|---|
class |
ApplicationNotFoundException
This exception is thrown on
ApplicationClientProtocol.getApplicationReport(GetApplicationReportRequest) API
when the Application doesn't exist in RM |
class |
InvalidApplicationMasterRequestException
This exception is thrown when an ApplicationMaster asks for resources by
calling
ApplicationMasterProtocol.allocate(AllocateRequest) API
without first registering by calling
ApplicationMasterProtocol.registerApplicationMaster(RegisterApplicationMasterRequest)
or if it tries to register more then once. |
class |
InvalidAuxServiceException
This exception is thrown by a NodeManager that is rejecting start-container
requests via
ContainerManagementProtocol.startContainers(StartContainersRequest)
for auxservices does not exist. |
class |
InvalidContainerException
This exception is thrown by a NodeManager that is rejecting start-container
requests via
ContainerManagementProtocol.startContainers(StartContainersRequest)
for containers allocated by a previous instance of the RM. |
class |
InvalidContainerReleaseException
This exception is thrown when an Application Master tries to release
containers not belonging to it using
ApplicationMasterProtocol.allocate(AllocateRequest) API. |
class |
InvalidResourceBlacklistRequestException
This exception is thrown when an application provides an invalid
ResourceBlacklistRequest specification for blacklisting of resources
in ApplicationMasterProtocol.allocate(AllocateRequest) API. |
class |
InvalidResourceRequestException
This exception is thrown when a resource requested via
ResourceRequest in the
ApplicationMasterProtocol.allocate(AllocateRequest) API is out of the
range of the configured lower and upper limits on resources. |
class |
NMNotYetReadyException
This exception is thrown on
ContainerManagementProtocol.startContainers(StartContainersRequest) API
when an NM starts from scratch but has not yet connected with RM. |
Modifier and Type | Method and Description |
---|---|
static YarnException |
RPCUtil.getRemoteException(String message)
Returns an instance of
YarnException |
static YarnException |
RPCUtil.getRemoteException(Throwable t)
Returns an instance of
YarnException |
Modifier and Type | Method and Description |
---|---|
static Void |
RPCUtil.unwrapAndThrowException(com.google.protobuf.ServiceException se)
Utility method that unwraps and returns appropriate exceptions.
|
Modifier and Type | Method and Description |
---|---|
protected void |
NodeStatusUpdaterImpl.registerWithRM() |
Modifier and Type | Method and Description |
---|---|
LocalizerHeartbeatResponse |
LocalizationProtocol.heartbeat(LocalizerStatus status) |
Modifier and Type | Method and Description |
---|---|
LocalizerHeartbeatResponse |
LocalizationProtocolPBClientImpl.heartbeat(LocalizerStatus status) |
Modifier and Type | Method and Description |
---|---|
protected void |
ContainerManagerImpl.authorizeGetAndStopContainerRequest(ContainerId containerId,
Container container,
boolean stopRequest,
NMTokenIdentifier identifier) |
protected void |
ContainerManagerImpl.authorizeStartRequest(NMTokenIdentifier nmTokenIdentifier,
ContainerTokenIdentifier containerTokenIdentifier) |
protected void |
ContainerManagerImpl.authorizeUser(UserGroupInformation remoteUgi,
NMTokenIdentifier nmTokenIdentifier) |
GetContainerStatusesResponse |
ContainerManagerImpl.getContainerStatuses(GetContainerStatusesRequest request)
Get a list of container statuses running on this NodeManager
|
protected UserGroupInformation |
ContainerManagerImpl.getRemoteUgi() |
StartContainersResponse |
ContainerManagerImpl.startContainers(StartContainersRequest requests)
Start a list of containers on this NodeManager.
|
StopContainersResponse |
ContainerManagerImpl.stopContainers(StopContainersRequest requests)
Stop a list of containers running on this NodeManager.
|
protected ContainerTokenIdentifier |
ContainerManagerImpl.verifyAndGetContainerTokenIdentifier(Token token,
ContainerTokenIdentifier containerTokenIdentifier) |
Modifier and Type | Method and Description |
---|---|
ApplicationReport |
AppReportFetcher.getApplicationReport(ApplicationId appId)
Get a report for the specified app.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.