Package org.apache.storm.nimbus
Interface IWorkerHeartbeatsRecoveryStrategy
-
- All Known Implementing Classes:
TimeOutWorkerHeartbeatsRecoveryStrategy
public interface IWorkerHeartbeatsRecoveryStrategyInterface for strategy to recover heartbeats when master gains leadership.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanisReady(Set<String> nodeIds)Function to decide if the heartbeats is ready.voidprepare(Map conf)Function to prepare the strategy.voidreportNodeId(String nodeId)report the node id to this strategy to help to decideisReady.
-
-
-
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 fromClusterState- Returns:
- true if all node worker heartbeats reported
-
reportNodeId
void reportNodeId(String nodeId)
report the node id to this strategy to help to decideisReady.- Parameters:
nodeId- the node id from reported SupervisorWorkerHeartbeats
-
-