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 and Description
TimerCallback()

Method Summary

Modifier and Type	Method and 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 Detail

TimerCallback

public TimerCallback()

Method Detail

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