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 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