public interface IWorkerHeartbeatsRecoveryStrategy
Interface for strategy to recover heartbeats when master gains leadership.
| 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. |
void prepare(Map conf)
Function to prepare the strategy.
conf - configboolean isReady(Set<String> nodeIds)
Function to decide if the heartbeats is ready.
nodeIds - all the node ids from current physical plan[assignments], read from ClusterStatevoid reportNodeId(String nodeId)
report the node id to this strategy to help to decide isReady.
nodeId - the node id from reported SupervisorWorkerHeartbeatsCopyright © 2021 The Apache Software Foundation. All rights reserved.