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

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	reportNodeId(String nodeId)	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