public class YarnResourceManagerCallbackHandler extends Object implements org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
Constructor and Description |
---|
YarnResourceManagerCallbackHandler() |
YarnResourceManagerCallbackHandler(akka.actor.ActorRef yarnFrameworkMaster) |
Modifier and Type | Method and Description |
---|---|
float |
getProgress() |
void |
initialize(akka.actor.ActorRef yarnFrameworkMaster) |
void |
onContainersAllocated(List<org.apache.hadoop.yarn.api.records.Container> containers) |
void |
onContainersCompleted(List<org.apache.hadoop.yarn.api.records.ContainerStatus> list) |
void |
onError(Throwable error) |
void |
onNodesUpdated(List<org.apache.hadoop.yarn.api.records.NodeReport> list) |
void |
onShutdownRequest() |
void |
setCurrentProgress(float progress)
Sets the current progress.
|
public YarnResourceManagerCallbackHandler()
public YarnResourceManagerCallbackHandler(akka.actor.ActorRef yarnFrameworkMaster)
public void initialize(akka.actor.ActorRef yarnFrameworkMaster)
public void setCurrentProgress(float progress)
progress
- The current progress fraction.public float getProgress()
getProgress
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onContainersCompleted(List<org.apache.hadoop.yarn.api.records.ContainerStatus> list)
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
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> list)
onNodesUpdated
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onError(Throwable error)
onError
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.