|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
@InterfaceAudience.Public @InterfaceStability.Unstable public interface AMRMClient
Field Summary | |
---|---|
static String |
ANY
Value used to define no locality |
Method Summary | |
---|---|
void |
addContainerRequest(org.apache.hadoop.yarn.client.AMRMClient.ContainerRequest req)
Request containers for resources before calling allocate |
AllocateResponse |
allocate(float progressIndicator)
Request additional containers and receive new container allocations. |
Resource |
getClusterAvailableResources()
Get the currently available resources in the cluster. |
int |
getClusterNodeCount()
Get the current number of nodes in the cluster. |
RegisterApplicationMasterResponse |
registerApplicationMaster(String appHostName,
int appHostPort,
String appTrackingUrl)
Register the application master. |
void |
releaseAssignedContainer(ContainerId containerId)
Release containers assigned by the Resource Manager. |
void |
removeContainerRequest(org.apache.hadoop.yarn.client.AMRMClient.ContainerRequest req)
Remove previous container request. |
void |
unregisterApplicationMaster(FinalApplicationStatus appStatus,
String appMessage,
String appTrackingUrl)
Unregister the application master. |
Methods inherited from interface org.apache.hadoop.yarn.service.Service |
---|
getConfig, getName, getServiceState, getStartTime, init, register, start, stop, unregister |
Field Detail |
---|
static final String ANY
Method Detail |
---|
RegisterApplicationMasterResponse registerApplicationMaster(String appHostName, int appHostPort, String appTrackingUrl) throws org.apache.hadoop.yarn.exceptions.YarnRemoteException
appHostName
- Name of the host on which master is runningappHostPort
- Port master is listening onappTrackingUrl
- URL at which the master info can be seen
RegisterApplicationMasterResponse
org.apache.hadoop.yarn.exceptions.YarnRemoteException
AllocateResponse allocate(float progressIndicator) throws org.apache.hadoop.yarn.exceptions.YarnRemoteException
addContainerRequest
are sent to the
ResourceManager
. New containers assigned to the master are
retrieved. Status of completed containers and node health updates are
also retrieved.
This also doubles up as a heartbeat to the ResourceManager and must be
made periodically.
The call may not always return any new allocations of containers.
App should not make concurrent allocate requests. May cause request loss.
progressIndicator
- Indicates progress made by the master
org.apache.hadoop.yarn.exceptions.YarnRemoteException
void unregisterApplicationMaster(FinalApplicationStatus appStatus, String appMessage, String appTrackingUrl) throws org.apache.hadoop.yarn.exceptions.YarnRemoteException
appStatus
- Success/Failure status of the masterappMessage
- Diagnostics message on failureappTrackingUrl
- New URL to get master info
org.apache.hadoop.yarn.exceptions.YarnRemoteException
void addContainerRequest(org.apache.hadoop.yarn.client.AMRMClient.ContainerRequest req)
allocate
req
- Resource requestvoid removeContainerRequest(org.apache.hadoop.yarn.client.AMRMClient.ContainerRequest req)
req
- Resource requestvoid releaseAssignedContainer(ContainerId containerId)
containerId
- Resource getClusterAvailableResources()
int getClusterNodeCount()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |