org.apache.flink.runtime.leaderretrieval

Interface LeaderRetrievalDriverFactory

All Known Implementing Classes:

KubernetesLeaderRetrievalDriverFactory, ZooKeeperLeaderRetrievalDriverFactory

public interface LeaderRetrievalDriverFactory

Factory for creating LeaderRetrievalDriver with different implementation.

Method Summary

Modifier and Type	Method and Description
LeaderRetrievalDriver	createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler, FatalErrorHandler fatalErrorHandler) Create a specific LeaderRetrievalDriver and start the necessary services.

Method Detail

createLeaderRetrievalDriver

LeaderRetrievalDriver createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
                                                  FatalErrorHandler fatalErrorHandler)
                                           throws Exception

Create a specific LeaderRetrievalDriver and start the necessary services. For example, NodeCache in Zookeeper, ConfigMap watcher in Kubernetes. They could get the leader information change events and need to notify the leader listener by LeaderRetrievalEventHandler.

Parameters:

leaderEventHandler - handler for the leader retrieval driver to notify leader change events.

fatalErrorHandler - fatal error handler

Throws:

Exception - when create a specific LeaderRetrievalDriver implementation and start the necessary services.