org.apache.drill.yarn.appMaster

Class Dispatcher.NodeCallback

java.lang.Object

org.apache.drill.yarn.appMaster.Dispatcher.NodeCallback

All Implemented Interfaces:

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

Enclosing class:

Dispatcher

public class Dispatcher.NodeCallback
extends Object
implements org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

Handle YARN Node Manager events. This is a separate class to clarify which events are, in fact, from the node manager.

Constructor Summary

Constructors

Constructor and Description
NodeCallback()

Method Summary

Modifier and Type	Method and Description
void	onContainerStarted(org.apache.hadoop.yarn.api.records.ContainerId containerId, Map<String,ByteBuffer> allServiceResponse)
void	onContainerStatusReceived(org.apache.hadoop.yarn.api.records.ContainerId containerId, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus)
void	onContainerStopped(org.apache.hadoop.yarn.api.records.ContainerId containerId)
void	onGetContainerStatusError(org.apache.hadoop.yarn.api.records.ContainerId containerId, Throwable t)
void	onStartContainerError(org.apache.hadoop.yarn.api.records.ContainerId containerId, Throwable t)
void	onStopContainerError(org.apache.hadoop.yarn.api.records.ContainerId containerId, Throwable t)

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeCallback

public NodeCallback()

Method Detail

onStartContainerError

public void onStartContainerError(org.apache.hadoop.yarn.api.records.ContainerId containerId,
                                  Throwable t)

Specified by:

onStartContainerError in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

onContainerStarted

public void onContainerStarted(org.apache.hadoop.yarn.api.records.ContainerId containerId,
                               Map<String,ByteBuffer> allServiceResponse)

Specified by:

onContainerStarted in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

onContainerStatusReceived

public void onContainerStatusReceived(org.apache.hadoop.yarn.api.records.ContainerId containerId,
                                      org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus)

Specified by:

onContainerStatusReceived in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

onGetContainerStatusError

public void onGetContainerStatusError(org.apache.hadoop.yarn.api.records.ContainerId containerId,
                                      Throwable t)

Specified by:

onGetContainerStatusError in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

onStopContainerError

public void onStopContainerError(org.apache.hadoop.yarn.api.records.ContainerId containerId,
                                 Throwable t)

Specified by:

onStopContainerError in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

onContainerStopped

public void onContainerStopped(org.apache.hadoop.yarn.api.records.ContainerId containerId)

Specified by:

onContainerStopped in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler