Package 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	Description
static interface	PulseRunnable.PulseCallback	Interface implemented to receive calls on each clock "tick."

Field Summary

Fields

Modifier and Type	Field	Description
AtomicBoolean	isLive

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

isLive

public AtomicBoolean isLive

Constructor Details

PulseRunnable

public PulseRunnable(int pulsePeriodMS,
 PulseRunnable.PulseCallback callback)

Method Details

run

public void run()

Specified by:

run in interface Runnable

stop

public void stop()