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 and Description
LeaderRetrievalService	KubernetesHaServices.createLeaderRetrievalService(String leaderName) Deprecated.
protected LeaderRetrievalService	KubernetesMultipleComponentLeaderElectionHaServices.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 and Description
protected abstract LeaderRetrievalService	AbstractHaServices.createLeaderRetrievalService(String leaderName) Create leader retrieval service with specified leaderName.
LeaderRetrievalService	ClientHighAvailabilityServices.getClusterRestEndpointLeaderRetriever() Get the leader retriever for the cluster's rest endpoint.
LeaderRetrievalService	AbstractHaServices.getClusterRestEndpointLeaderRetriever()
default LeaderRetrievalService	HighAvailabilityServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	AbstractHaServices.getDispatcherLeaderRetriever()
LeaderRetrievalService	HighAvailabilityServices.getDispatcherLeaderRetriever() Gets the leader retriever for the dispatcher.
LeaderRetrievalService	AbstractHaServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	HighAvailabilityServices.getJobManagerLeaderRetriever(JobID jobID) Deprecated. This method should only be used by the legacy code where the JobManager acts as the master.
LeaderRetrievalService	AbstractHaServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
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 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	StandaloneHaServices.getClusterRestEndpointLeaderRetriever()
LeaderRetrievalService	StandaloneClientHAServices.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
protected LeaderRetrievalService	ZooKeeperMultipleComponentLeaderElectionHaServices.createLeaderRetrievalService(String leaderPath)
protected LeaderRetrievalService	ZooKeeperHaServices.createLeaderRetrievalService(String leaderPath) Deprecated.
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 and 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 and Description
static InetAddress	LeaderRetrievalUtils.findConnectingAddress(LeaderRetrievalService leaderRetrievalService, java.time.Duration timeout, RpcSystemUtils rpcSystemUtils)
static LeaderConnectionInfo	LeaderRetrievalUtils.retrieveLeaderConnectionInfo(LeaderRetrievalService leaderRetrievalService, java.time.Duration timeout) Retrieves the leader akka url and the current leader session ID.