@InterfaceAudience.Private @InterfaceStability.Unstable public class AMRMClientAsyncImpl<T extends AMRMClient.ContainerRequest> extends AMRMClientAsync<T>
AMRMClientAsync.AbstractCallbackHandler, AMRMClientAsync.CallbackHandler
client, handler, heartbeatIntervalMs
Constructor and Description |
---|
AMRMClientAsyncImpl(AMRMClient<T> client,
int intervalMs,
AMRMClientAsync.AbstractCallbackHandler callbackHandler) |
AMRMClientAsyncImpl(AMRMClient<T> client,
int intervalMs,
AMRMClientAsync.CallbackHandler callbackHandler)
Deprecated.
|
AMRMClientAsyncImpl(int intervalMs,
AMRMClientAsync.AbstractCallbackHandler callbackHandler) |
AMRMClientAsyncImpl(int intervalMs,
AMRMClientAsync.CallbackHandler callbackHandler)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
addContainerRequest(T req)
Request containers for resources before calling
allocate |
org.apache.hadoop.yarn.api.records.Resource |
getAvailableResources()
Get the currently available resources in the cluster.
|
int |
getClusterNodeCount()
Get the current number of nodes in the cluster.
|
List<? extends Collection<T>> |
getMatchingRequests(org.apache.hadoop.yarn.api.records.Priority priority,
String resourceName,
org.apache.hadoop.yarn.api.records.Resource capability) |
org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse |
registerApplicationMaster(String appHostName,
int appHostPort,
String appTrackingUrl)
Registers this application master with the resource manager.
|
void |
releaseAssignedContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
Release containers assigned by the Resource Manager.
|
void |
removeContainerRequest(T req)
Remove previous container request.
|
void |
requestContainerUpdate(org.apache.hadoop.yarn.api.records.Container container,
org.apache.hadoop.yarn.api.records.UpdateContainerRequest updateContainerRequest)
Request a container update before calling
allocate . |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
protected void |
serviceStop()
Tells the heartbeat and handler threads to stop and waits for them to
terminate.
|
void |
unregisterApplicationMaster(org.apache.hadoop.yarn.api.records.FinalApplicationStatus appStatus,
String appMessage,
String appTrackingUrl)
Unregister the application master.
|
void |
updateBlacklist(List<String> blacklistAdditions,
List<String> blacklistRemovals)
Update application's blacklist with addition or removal resources.
|
createAMRMClientAsync, createAMRMClientAsync, createAMRMClientAsync, createAMRMClientAsync, getMatchingRequests, getMatchingRequests, getRegisteredTimelineV2Client, registerTimelineV2Client, requestContainerResourceChange, setHeartbeatInterval, waitFor, waitFor, waitFor
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public AMRMClientAsyncImpl(int intervalMs, AMRMClientAsync.AbstractCallbackHandler callbackHandler)
intervalMs
- heartbeat interval in milliseconds between AM and RMcallbackHandler
- callback handler that processes responses from
the ResourceManager
public AMRMClientAsyncImpl(AMRMClient<T> client, int intervalMs, AMRMClientAsync.AbstractCallbackHandler callbackHandler)
@Deprecated public AMRMClientAsyncImpl(int intervalMs, AMRMClientAsync.CallbackHandler callbackHandler)
AMRMClientAsyncImpl(int,
AMRMClientAsync.AbstractCallbackHandler)
instead.@InterfaceAudience.Private @Deprecated public AMRMClientAsyncImpl(AMRMClient<T> client, int intervalMs, AMRMClientAsync.CallbackHandler callbackHandler)
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
public List<? extends Collection<T>> getMatchingRequests(org.apache.hadoop.yarn.api.records.Priority priority, String resourceName, org.apache.hadoop.yarn.api.records.Resource capability)
getMatchingRequests
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
public org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse registerApplicationMaster(String appHostName, int appHostPort, String appTrackingUrl) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
registerApplicationMaster
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public void unregisterApplicationMaster(org.apache.hadoop.yarn.api.records.FinalApplicationStatus appStatus, String appMessage, String appTrackingUrl) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
unregisterApplicationMaster
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
appStatus
- Success/Failure status of the masterappMessage
- Diagnostics message on failureappTrackingUrl
- New URL to get master infoorg.apache.hadoop.yarn.exceptions.YarnException
IOException
public void addContainerRequest(T req)
allocate
addContainerRequest
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
req
- Resource requestpublic void removeContainerRequest(T req)
removeContainerRequest
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
req
- Resource requestpublic void requestContainerUpdate(org.apache.hadoop.yarn.api.records.Container container, org.apache.hadoop.yarn.api.records.UpdateContainerRequest updateContainerRequest)
AMRMClientAsync
allocate
.
Any previous pending update request of the same container will be
removed.requestContainerUpdate
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
container
- The container returned from the last successful resource
allocation or updateupdateContainerRequest
- The UpdateContainerRequest
.public void releaseAssignedContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
releaseAssignedContainer
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
containerId
- public org.apache.hadoop.yarn.api.records.Resource getAvailableResources()
getAvailableResources
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
public int getClusterNodeCount()
getClusterNodeCount
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
public void updateBlacklist(List<String> blacklistAdditions, List<String> blacklistRemovals)
updateBlacklist
in class AMRMClientAsync<T extends AMRMClient.ContainerRequest>
blacklistAdditions
- list of resources which should be added to the
application blacklistblacklistRemovals
- list of resources which should be removed from the
application blacklistCopyright © 2017 Apache Software Foundation. All Rights Reserved.