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 Description ReportWorkerHeartbeats(Map<String,Object> conf, Supervisor supervisor)
-