org.apache.drill.yarn.appMaster

Class PulseRunnable

java.lang.Object

org.apache.drill.yarn.appMaster.PulseRunnable

All Implemented Interfaces:

Runnable

public class PulseRunnable
extends Object
implements Runnable

Clock driver that calls a callback once each pulse period. Used to react to time-based events such as timeouts, checking for changed files, etc. This is called a "pulse" because it is periodic, like your pulse. But, unlike the "heartbeat" between the AM and YARN or the AM and ZK, this is purely internal.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	PulseRunnable.PulseCallback Interface implemented to receive calls on each clock "tick."

Field Summary

Fields

Modifier and Type	Field and Description
AtomicBoolean	isLive

Constructor Summary

Constructors

Constructor and Description
PulseRunnable(int pulsePeriodMS, PulseRunnable.PulseCallback callback)

Method Summary

Modifier and Type	Method and Description
void	run()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

isLive

public AtomicBoolean isLive

Constructor Detail

PulseRunnable

public PulseRunnable(int pulsePeriodMS,
                     PulseRunnable.PulseCallback callback)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

stop

public void stop()