org.apache.flink.yarn

Class YarnResourceManagerCallbackHandler

java.lang.Object

org.apache.flink.yarn.YarnResourceManagerCallbackHandler

All Implemented Interfaces:

org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

public class YarnResourceManagerCallbackHandler
extends Object
implements org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

This class reacts to callbacks from the YARN Resource Manager. In order to preserve actor concurrency safety, this class simply sends corresponding messages to the Yarn resource master actor.

Constructor Summary

Constructors

Constructor and Description
YarnResourceManagerCallbackHandler()
YarnResourceManagerCallbackHandler(akka.actor.ActorRef yarnFrameworkMaster)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

YarnResourceManagerCallbackHandler

public YarnResourceManagerCallbackHandler()

YarnResourceManagerCallbackHandler

public YarnResourceManagerCallbackHandler(akka.actor.ActorRef yarnFrameworkMaster)

Method Detail

initialize

public void initialize(akka.actor.ActorRef yarnFrameworkMaster)

setCurrentProgress

public void setCurrentProgress(float progress)

Sets the current progress.

Parameters:

progress - The current progress fraction.

getProgress

public float getProgress()

Specified by:

getProgress in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

onContainersCompleted

public void onContainersCompleted(List<org.apache.hadoop.yarn.api.records.ContainerStatus> list)

Specified by:

onContainersCompleted in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

onContainersAllocated

public void onContainersAllocated(List<org.apache.hadoop.yarn.api.records.Container> containers)

Specified by:

onContainersAllocated in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

onShutdownRequest

public void onShutdownRequest()

Specified by:

onShutdownRequest in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

onNodesUpdated

public void onNodesUpdated(List<org.apache.hadoop.yarn.api.records.NodeReport> list)

Specified by:

onNodesUpdated in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

onError

public void onError(Throwable error)

Specified by:

onError in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler