Package 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
- 
Method Details- 
prepareFunction to prepare the strategy.- Parameters:
- conf- config
 
- 
isReadyFunction 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
 
- 
reportNodeIdreport the node id to this strategy to help to decideisReady.- Parameters:
- nodeId- the node id from reported SupervisorWorkerHeartbeats
 
 
-