Class 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.
    • Method Detail

      • run

        public void run()
        Specified by:
        run in interface Runnable