org.apache.drill.yarn.appMaster

Class Dispatcher

java.lang.Object

org.apache.drill.yarn.appMaster.Dispatcher

public class Dispatcher
extends Object

Dispatches YARN, timer and ZooKeeper events to the cluster controller. Allows the controller to be independent of the plumbing needed to receive events. Divides work among various components to separate concerns. Three streams of events feed into an app master "strategy". The three streams are

1. Resource manager
2. Node manager
3. Timer

This class is "lightly" multi-threaded: it responds to events from the RM, NM and timer threads. Within each of these, events are sequential. So, synchronization is needed across the three event types, but not within event types. (That is, we won't see two RM events, say, occurring at the same time from separate threads.)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Dispatcher.NodeCallback Handle YARN Node Manager events.
class	Dispatcher.TimerCallback Handle timer events: a constant tick to handle time-based actions such as timeouts.

Constructor Summary

Constructors

Constructor and Description
Dispatcher(int timerPeriodMs)

Method Summary

Modifier and Type	Method and Description
ClusterController	getController()
String	getTrackingUrl()
void	registerAddOn(DispatcherAddOn addOn)
void	registerPollable(Pollable pollable)
void	run()
void	setAMRegistrar(AMRegistrar registrar)
void	setHttpPort(int port)
void	setTrackingUrl(String trackingUrl)
void	setYarn(AMYarnFacade yarn)
boolean	start() Start the dispatcher by initializing YARN and registering the AM.

Methods inherited from class java.lang.Object

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

Constructor Detail

Dispatcher

public Dispatcher(int timerPeriodMs)

Method Detail

setYarn

public void setYarn(AMYarnFacade yarn)
             throws YarnFacadeException

Throws:

YarnFacadeException

getController

public ClusterController getController()

registerPollable

public void registerPollable(Pollable pollable)

registerAddOn

public void registerAddOn(DispatcherAddOn addOn)

setHttpPort

public void setHttpPort(int port)

setTrackingUrl

public void setTrackingUrl(String trackingUrl)

getTrackingUrl

public String getTrackingUrl()

setAMRegistrar

public void setAMRegistrar(AMRegistrar registrar)

start

public boolean start()
              throws YarnFacadeException

Start the dispatcher by initializing YARN and registering the AM.

Returns:

true if successful, false if the dispatcher did not start.

Throws:

YarnFacadeException

run

public void run()
         throws YarnFacadeException

Throws:

YarnFacadeException