org.apache.storm.nimbus

## Interface IWorkerHeartbeatsRecoveryStrategy

- All Known Implementing Classes:
    TimeOutWorkerHeartbeatsRecoveryStrategy

      public interface IWorkerHeartbeatsRecoveryStrategy

  Interface for strategy to recover heartbeats when master gains leadership.

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    Modifier and Type | Method and Description
    --- | ---
    `boolean` | `isReady(Set<String> nodeIds)` Function to decide if the heartbeats is ready.
    `void` | `prepare(Map conf)` Function to prepare the strategy.
    `void` | `reportNodeId(String nodeId)` report the node id to this strategy to help to decide `isReady`.

- - ### 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

Copyright © 2021 The Apache Software Foundation. All rights reserved.