public class YarnJobManager.AMRMClientAsyncHandler extends Object implements org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
Constructor and Description |
---|
AMRMClientAsyncHandler()
Heartbeats with the resource manager and informs of container updates.
|
Modifier and Type | Method and Description |
---|---|
float |
getProgress() |
void |
onContainersAllocated(List<org.apache.hadoop.yarn.api.records.Container> containers) |
void |
onContainersCompleted(List<org.apache.hadoop.yarn.api.records.ContainerStatus> statuses) |
void |
onError(Throwable e) |
void |
onNodesUpdated(List<org.apache.hadoop.yarn.api.records.NodeReport> updatedNodes) |
void |
onShutdownRequest() |
public AMRMClientAsyncHandler()
public void onError(Throwable e)
onError
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public float getProgress()
getProgress
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onShutdownRequest()
onShutdownRequest
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onNodesUpdated(List<org.apache.hadoop.yarn.api.records.NodeReport> updatedNodes)
onNodesUpdated
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onContainersCompleted(List<org.apache.hadoop.yarn.api.records.ContainerStatus> statuses)
onContainersCompleted
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onContainersAllocated(List<org.apache.hadoop.yarn.api.records.Container> containers)
onContainersAllocated
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.