org.apache.flink.runtime.leaderretrieval

Interface LeaderRetrievalDriver

All Known Implementing Classes:

KubernetesLeaderRetrievalDriver, ZooKeeperLeaderRetrievalDriver

public interface LeaderRetrievalDriver

A LeaderRetrievalDriver is responsible for retrieves the current leader which has been elected by the LeaderElectionDriver.

Important: The LeaderRetrievalDriver could not guarantee that there is no LeaderRetrievalEventHandler callbacks happen after close().

Method Summary

Modifier and Type	Method and Description
void	close() Close the services used for leader retrieval.

Method Detail

close

void close()
    throws Exception

Close the services used for leader retrieval.

Throws:

Exception