Interface IWorkerHeartbeatsRecoveryStrategy

All Known Implementing Classes:
TimeOutWorkerHeartbeatsRecoveryStrategy

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

    Modifier and Type
    Method
    Description
    boolean
    isReady(Set<String> nodeIds)
    Function to decide if the heartbeats is ready.
    void
    prepare(Map conf)
    Function to prepare the strategy.
    void
    report the node id to this strategy to help to decide isReady.
  • Method Details

    • 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