Interface IWorkerHeartbeatsRecoveryStrategy

  • All Known Implementing Classes:
    TimeOutWorkerHeartbeatsRecoveryStrategy

    public interface IWorkerHeartbeatsRecoveryStrategy
    Interface for strategy to recover heartbeats when master gains leadership.
    • Method Detail

      • prepare

        void prepare​(Map conf)
        Function to prepare the strategy.
        Parameters:
        conf - config
      • isReady

        boolean isReady​(Set<String> nodeIds)
        Function to decide if the heartbeats is ready.
        Parameters:
        nodeIds - all the node ids from current physical plan[assignments], read from ClusterState
        Returns:
        true if all node worker heartbeats reported
      • reportNodeId

        void reportNodeId​(String nodeId)
        report the node id to this strategy to help to decide isReady.
        Parameters:
        nodeId - the node id from reported SupervisorWorkerHeartbeats