org.apache.storm.daemon.supervisor.timer

Class ReportWorkerHeartbeats

java.lang.Object

org.apache.storm.daemon.supervisor.timer.ReportWorkerHeartbeats

All Implemented Interfaces:

Runnable

public class ReportWorkerHeartbeats
extends Object
implements Runnable

Runnable reporting local worker reported heartbeats to master, supervisor should take care the of the heartbeats integrity for the master heartbeats recovery, a non-null node id means that the heartbeats are full, and master can go on to check and wait others nodes when doing a heartbeats recovery.

Constructor Summary

Constructors

Constructor and Description
ReportWorkerHeartbeats(Map<String,Object> conf, Supervisor supervisor)

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReportWorkerHeartbeats

public ReportWorkerHeartbeats(Map<String,Object> conf,
                              Supervisor supervisor)

Method Detail

run

public void run()

Specified by:

run in interface Runnable