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

Packages that use LeaderRetrievalService

Package	Description
org.apache.flink.kubernetes.highavailability
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.kubernetes.highavailability

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

Modifier and Type	Method	Description
protected LeaderRetrievalService	KubernetesLeaderElectionHaServices.createLeaderRetrievalService(String componentId)

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

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

Modifier and Type	Method	Description
protected abstract LeaderRetrievalService	AbstractHaServices.createLeaderRetrievalService(String leaderName)	Create leader retrieval service with specified leaderName.
LeaderRetrievalService	AbstractHaServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	ClientHighAvailabilityServices.getClusterRestEndpointLeaderRetriever()	Get the leader retriever for the cluster's rest endpoint.
default LeaderRetrievalService	HighAvailabilityServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	AbstractHaServices.getDispatcherLeaderRetriever()
LeaderRetrievalService	HighAvailabilityServices.getDispatcherLeaderRetriever()	Gets the leader retriever for the dispatcher.
LeaderRetrievalService	AbstractHaServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	AbstractHaServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
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	AbstractHaServices.getResourceManagerLeaderRetriever()
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	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	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	Description
protected LeaderRetrievalService	ZooKeeperLeaderElectionHaServices.createLeaderRetrievalService(String componentId)
LeaderRetrievalService	ZooKeeperClientHAServices.getClusterRestEndpointLeaderRetriever()

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

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

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

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	Description
static InetAddress	LeaderRetrievalUtils.findConnectingAddress(LeaderRetrievalService leaderRetrievalService, Duration timeout, RpcSystemUtils rpcSystemUtils)
static LeaderInformation	LeaderRetrievalUtils.retrieveLeaderInformation(LeaderRetrievalService leaderRetrievalService, Duration timeout)	Retrieves the leader pekko url and the current leader session ID.