org.apache.reef.task

Class HeartBeatTriggerManager

java.lang.Object

org.apache.reef.task.HeartBeatTriggerManager

public class HeartBeatTriggerManager
extends Object

Helper class for immediately sending heartbeat messages. This can be used together with TaskMessageSource to push urgent messages to the Driver.

CAUTION: Do not overuse as the Driver can be saturated with heartbeats.

See Also:

REEF-33 for the ongoing discussion of alternatives to this design.

Method Summary

Modifier and Type	Method and Description
void	triggerHeartBeat() Immediately send a heartbeat message to the Driver.

Methods inherited from class java.lang.Object

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

Method Detail

triggerHeartBeat

public void triggerHeartBeat()

Immediately send a heartbeat message to the Driver.