Uses of Interface
org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService

Packages that use LeaderRetrievalService

Package	Description
org.apache.flink.runtime.highavailability
org.apache.flink.runtime.highavailability.nonha.embedded
org.apache.flink.runtime.highavailability.nonha.standalone
org.apache.flink.runtime.highavailability.zookeeper
org.apache.flink.runtime.leaderretrieval
org.apache.flink.runtime.util

Uses of LeaderRetrievalService in org.apache.flink.runtime.highavailability

Methods in org.apache.flink.runtime.highavailability that return LeaderRetrievalService

Modifier and Type	Method and Description
LeaderRetrievalService	ClientHighAvailabilityServices.getClusterRestEndpointLeaderRetriever() Get the leader retriever for the cluster's rest endpoint.
default LeaderRetrievalService	HighAvailabilityServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	HighAvailabilityServices.getDispatcherLeaderRetriever() Gets the leader retriever for the dispatcher.
LeaderRetrievalService	HighAvailabilityServices.getJobManagerLeaderRetriever(JobID jobID) Deprecated. This method should only be used by the legacy code where the JobManager acts as the master.
LeaderRetrievalService	HighAvailabilityServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress) Gets the leader retriever for the job JobMaster which is responsible for the given job.
LeaderRetrievalService	HighAvailabilityServices.getResourceManagerLeaderRetriever() Gets the leader retriever for the cluster's resource manager.
default LeaderRetrievalService	HighAvailabilityServices.getWebMonitorLeaderRetriever() Deprecated. just use HighAvailabilityServices.getClusterRestEndpointLeaderRetriever() instead of this method.

Uses of LeaderRetrievalService in org.apache.flink.runtime.highavailability.nonha.embedded

Methods in org.apache.flink.runtime.highavailability.nonha.embedded that return LeaderRetrievalService

Modifier and Type	Method and Description
LeaderRetrievalService	EmbeddedLeaderService.createLeaderRetrievalService()
LeaderRetrievalService	EmbeddedHaServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	EmbeddedHaServices.getDispatcherLeaderRetriever()
LeaderRetrievalService	EmbeddedHaServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	EmbeddedHaServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
LeaderRetrievalService	EmbeddedHaServices.getResourceManagerLeaderRetriever()

Uses of LeaderRetrievalService in org.apache.flink.runtime.highavailability.nonha.standalone

Methods in org.apache.flink.runtime.highavailability.nonha.standalone that return LeaderRetrievalService

Modifier and Type	Method and Description
LeaderRetrievalService	StandaloneClientHAServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	StandaloneHaServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	StandaloneHaServices.getDispatcherLeaderRetriever()
LeaderRetrievalService	StandaloneHaServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	StandaloneHaServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
LeaderRetrievalService	StandaloneHaServices.getResourceManagerLeaderRetriever()

Uses of LeaderRetrievalService in org.apache.flink.runtime.highavailability.zookeeper

Methods in org.apache.flink.runtime.highavailability.zookeeper that return LeaderRetrievalService

Modifier and Type	Method and Description
LeaderRetrievalService	ZooKeeperClientHAServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	ZooKeeperHaServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	ZooKeeperHaServices.getDispatcherLeaderRetriever()
LeaderRetrievalService	ZooKeeperHaServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	ZooKeeperHaServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
LeaderRetrievalService	ZooKeeperHaServices.getResourceManagerLeaderRetriever()

Uses of LeaderRetrievalService in org.apache.flink.runtime.leaderretrieval

Classes in org.apache.flink.runtime.leaderretrieval that implement LeaderRetrievalService

Modifier and Type	Class and Description
class	StandaloneLeaderRetrievalService Standalone implementation of the LeaderRetrievalService.
class	ZooKeeperLeaderRetrievalService The counterpart to the ZooKeeperLeaderElectionService.

Uses of LeaderRetrievalService in org.apache.flink.runtime.util

Methods in org.apache.flink.runtime.util with parameters of type LeaderRetrievalService

Modifier and Type	Method and Description
static InetAddress	LeaderRetrievalUtils.findConnectingAddress(LeaderRetrievalService leaderRetrievalService, java.time.Duration timeout)
static LeaderConnectionInfo	LeaderRetrievalUtils.retrieveLeaderConnectionInfo(LeaderRetrievalService leaderRetrievalService, java.time.Duration timeout) Retrieves the leader akka url and the current leader session ID.