Class ReportWorkerHeartbeats

All Implemented Interfaces:

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 Details

  • Method Details

    • run

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