Package | Description |
---|---|
org.apache.hadoop.yarn.api | |
org.apache.hadoop.yarn.conf | |
org.apache.hadoop.yarn.exceptions | |
org.apache.hadoop.yarn.server.api |
Modifier and Type | Method and Description |
---|---|
AllocateResponse |
ApplicationMasterProtocol.allocate(AllocateRequest request)
The main interface between an
ApplicationMaster and the
ResourceManager . |
CancelDelegationTokenResponse |
ApplicationBaseProtocol.cancelDelegationToken(CancelDelegationTokenRequest request)
Cancel an existing delegation
Token . |
ReservationDeleteResponse |
ApplicationClientProtocol.deleteReservation(ReservationDeleteRequest request)
The interface used by clients to remove an existing Reservation.
|
FailApplicationAttemptResponse |
ApplicationClientProtocol.failApplicationAttempt(FailApplicationAttemptRequest request)
The interface used by clients to request the
ResourceManager to fail an application attempt. |
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. |
GetApplicationAttemptReportResponse |
ApplicationBaseProtocol.getApplicationAttemptReport(GetApplicationAttemptReportRequest request)
The interface used by clients to get a report of an Application Attempt
from the
ResourceManager or
ApplicationHistoryServer |
GetApplicationAttemptsResponse |
ApplicationBaseProtocol.getApplicationAttempts(GetApplicationAttemptsRequest request)
The interface used by clients to get a report of all Application attempts
in the cluster from the
ResourceManager or
ApplicationHistoryServer |
GetApplicationReportResponse |
ApplicationBaseProtocol.getApplicationReport(GetApplicationReportRequest request)
The interface used by clients to get a report of an Application from the
ResourceManager or ApplicationHistoryServer . |
GetApplicationsResponse |
ApplicationBaseProtocol.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 or ApplicationHistoryServer . |
GetClusterMetricsResponse |
ApplicationClientProtocol.getClusterMetrics(GetClusterMetricsRequest request)
The interface used by clients to get metrics about the cluster from
the
ResourceManager . |
GetClusterNodeLabelsResponse |
ApplicationClientProtocol.getClusterNodeLabels(GetClusterNodeLabelsRequest request)
The interface used by client to get node labels in the cluster
|
GetClusterNodesResponse |
ApplicationClientProtocol.getClusterNodes(GetClusterNodesRequest request)
The interface used by clients to get a report of all nodes
in the cluster from the
ResourceManager . |
GetContainerReportResponse |
ApplicationBaseProtocol.getContainerReport(GetContainerReportRequest request)
The interface used by clients to get a report of an Container from the
ResourceManager or ApplicationHistoryServer |
GetContainersResponse |
ApplicationBaseProtocol.getContainers(GetContainersRequest request)
The interface used by clients to get a report of Containers for an
application attempt from the
ResourceManager or
ApplicationHistoryServer |
GetContainerStatusesResponse |
ContainerManagementProtocol.getContainerStatuses(GetContainerStatusesRequest request)
The API used by the
ApplicationMaster to request for current
statuses of Container s from the NodeManager . |
GetDelegationTokenResponse |
ApplicationBaseProtocol.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.
|
GetLabelsToNodesResponse |
ApplicationClientProtocol.getLabelsToNodes(GetLabelsToNodesRequest request)
The interface used by client to get labels to nodes mappings
in existing cluster
|
GetNewApplicationResponse |
ApplicationClientProtocol.getNewApplication(GetNewApplicationRequest request)
The interface used by clients to obtain a new
ApplicationId for
submitting new applications. |
GetNewReservationResponse |
ApplicationClientProtocol.getNewReservation(GetNewReservationRequest request)
The interface used by clients to obtain a new
ReservationId for
submitting new reservations. |
GetNodesToLabelsResponse |
ApplicationClientProtocol.getNodeToLabels(GetNodesToLabelsRequest request)
The interface used by client to get node to labels mappings in existing cluster
|
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 . |
IncreaseContainersResourceResponse |
ContainerManagementProtocol.increaseContainersResource(IncreaseContainersResourceRequest request)
The API used by the
ApplicationMaster to request for
resource increase of running containers on the NodeManager . |
ReservationListResponse |
ApplicationClientProtocol.listReservations(ReservationListRequest request)
The interface used by clients to get the list of reservations in a plan.
|
MoveApplicationAcrossQueuesResponse |
ApplicationClientProtocol.moveApplicationAcrossQueues(MoveApplicationAcrossQueuesRequest request)
Move an application to a new queue.
|
RegisterApplicationMasterResponse |
ApplicationMasterProtocol.registerApplicationMaster(RegisterApplicationMasterRequest request)
The interface used by a new
ApplicationMaster to register with
the ResourceManager . |
ReleaseSharedCacheResourceResponse |
ClientSCMProtocol.release(ReleaseSharedCacheResourceRequest request)
The interface used by clients to release a resource with the
SharedCacheManager. This method is called once an application
is no longer using a claimed resource in the shared cache. |
RenewDelegationTokenResponse |
ApplicationBaseProtocol.renewDelegationToken(RenewDelegationTokenRequest request)
Renew an existing delegation
Token . |
SignalContainerResponse |
ContainerManagementProtocol.signalToContainer(SignalContainerRequest request) |
SignalContainerResponse |
ApplicationClientProtocol.signalToContainer(SignalContainerRequest request)
The interface used by clients to request the
ResourceManager to signal a container. |
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. |
ReservationSubmissionResponse |
ApplicationClientProtocol.submitReservation(ReservationSubmissionRequest request)
The interface used by clients to submit a new reservation to the
ResourceManager . |
UpdateApplicationPriorityResponse |
ApplicationClientProtocol.updateApplicationPriority(UpdateApplicationPriorityRequest request)
The interface used by client to set priority of an application.
|
ReservationUpdateResponse |
ApplicationClientProtocol.updateReservation(ReservationUpdateRequest request)
The interface used by clients to update an existing Reservation.
|
UseSharedCacheResourceResponse |
ClientSCMProtocol.use(UseSharedCacheResourceRequest request)
The interface used by clients to claim a resource with the
SharedCacheManager. The client uses a checksum to identify the
resource and an ApplicationId to identify which application will be
using the resource. |
Modifier and Type | Method and Description |
---|---|
abstract InputStream |
ConfigurationProvider.getConfigurationInputStream(org.apache.hadoop.conf.Configuration bootstrapConf,
String name)
Opens an InputStream at the indicated file
|
Modifier and Type | Class and Description |
---|---|
class |
ApplicationAttemptNotFoundException
This exception is thrown on
(GetApplicationAttemptReportRequest)
API when the Application Attempt doesn't exist in Application History Server or
ApplicationMasterProtocol.allocate(AllocateRequest) if application
doesn't exist in RM. |
class |
ApplicationIdNotProvidedException
Exception to be thrown when Client submit an application without
providing
ApplicationId in ApplicationSubmissionContext . |
class |
ApplicationMasterNotRegisteredException
This exception is thrown when an Application Master tries to unregister by calling
ApplicationMasterProtocol.finishApplicationMaster(FinishApplicationMasterRequest)
API without first registering by calling
ApplicationMasterProtocol.registerApplicationMaster(RegisterApplicationMasterRequest)
or after an RM restart. |
class |
ApplicationNotFoundException
This exception is thrown on
(GetApplicationReportRequest) API
when the Application doesn't exist in RM and AHS |
class |
ContainerNotFoundException
This exception is thrown on
(GetContainerReportRequest)
API when the container doesn't exist in AHS |
class |
InvalidApplicationMasterRequestException
This exception is thrown when an ApplicationMaster asks for resources by
calling
ApplicationMasterProtocol.allocate(AllocateRequest)
without first registering by calling
ApplicationMasterProtocol.registerApplicationMaster(RegisterApplicationMasterRequest)
or if it tries to register more than 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 |
InvalidLabelResourceRequestException
This exception is thrown when a resource requested via
ResourceRequest in the
ApplicationMasterProtocol.allocate(AllocateRequest) when requested
label is not having permission to access. |
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. |
Copyright © 2018 Apache Software Foundation. All Rights Reserved.