Package org.apache.drill.yarn.appMaster

Class Dispatcher.TimerCallback

java.lang.Object

org.apache.drill.yarn.appMaster.Dispatcher.TimerCallback

All Implemented Interfaces:

PulseRunnable.PulseCallback

Enclosing class:

Dispatcher

public class Dispatcher.TimerCallback
extends Object
implements PulseRunnable.PulseCallback

Handle timer events: a constant tick to handle time-based actions such as timeouts.

Constructor Summary

Constructors

Constructor	Description
TimerCallback()

Method Summary

Modifier and Type	Method	Description
void	onTick(long curTime)	The lifecycle of each task is driven by RM and NM callbacks.

Methods inherited from class java.lang.Object

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

Constructor Details

TimerCallback

public TimerCallback()

Method Details

onTick

public void onTick(long curTime)

The lifecycle of each task is driven by RM and NM callbacks. We use the timer to start the process. While this is overkill here, in a real app, we'd check requested resource levels (which might change) and number of tasks (which might change if tasks die), and take corrective action: adding or removing tasks.

Specified by:

onTick in interface PulseRunnable.PulseCallback