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

Packages that use LeaderRetrievalService

Package	Description
org.apache.flink.client.program.rest
org.apache.flink.runtime.entrypoint.component
org.apache.flink.runtime.highavailability
org.apache.flink.runtime.highavailability.nonha.embedded
org.apache.flink.runtime.highavailability.nonha.leaderelection
org.apache.flink.runtime.highavailability.nonha.standalone
org.apache.flink.runtime.highavailability.zookeeper
org.apache.flink.runtime.leaderretrieval
org.apache.flink.runtime.util
org.apache.flink.yarn.highavailability

Uses of LeaderRetrievalService in org.apache.flink.client.program.rest

Constructors in org.apache.flink.client.program.rest with parameters of type LeaderRetrievalService

Constructor and Description
RestClusterClient(Configuration config, T clusterId, LeaderRetrievalService webMonitorRetrievalService)

Uses of LeaderRetrievalService in org.apache.flink.runtime.entrypoint.component

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

Modifier and Type	Method and Description
protected DispatcherResourceManagerComponent<Dispatcher>	SessionDispatcherResourceManagerComponentFactory.createDispatcherResourceManagerComponent(Dispatcher dispatcher, ResourceManager<?> resourceManager, LeaderRetrievalService dispatcherLeaderRetrievalService, LeaderRetrievalService resourceManagerRetrievalService, WebMonitorEndpoint<?> webMonitorEndpoint, JobManagerMetricGroup jobManagerMetricGroup)
protected DispatcherResourceManagerComponent<MiniDispatcher>	JobDispatcherResourceManagerComponentFactory.createDispatcherResourceManagerComponent(MiniDispatcher dispatcher, ResourceManager<?> resourceManager, LeaderRetrievalService dispatcherLeaderRetrievalService, LeaderRetrievalService resourceManagerRetrievalService, WebMonitorEndpoint<?> webMonitorEndpoint, JobManagerMetricGroup jobManagerMetricGroup)
protected abstract DispatcherResourceManagerComponent<T>	AbstractDispatcherResourceManagerComponentFactory.createDispatcherResourceManagerComponent(T dispatcher, ResourceManager<?> resourceManager, LeaderRetrievalService dispatcherLeaderRetrievalService, LeaderRetrievalService resourceManagerRetrievalService, WebMonitorEndpoint<?> webMonitorEndpoint, JobManagerMetricGroup jobManagerMetricGroup)

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	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.
LeaderRetrievalService	HighAvailabilityServices.getWebMonitorLeaderRetriever()

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.getDispatcherLeaderRetriever()
LeaderRetrievalService	EmbeddedHaServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	EmbeddedHaServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
LeaderRetrievalService	EmbeddedHaServices.getResourceManagerLeaderRetriever()
LeaderRetrievalService	EmbeddedHaServices.getWebMonitorLeaderRetriever()

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

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

Modifier and Type	Method and Description
LeaderRetrievalService	SingleLeaderElectionService.createLeaderRetrievalService()

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.getDispatcherLeaderRetriever()
LeaderRetrievalService	StandaloneHaServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	StandaloneHaServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
LeaderRetrievalService	StandaloneHaServices.getResourceManagerLeaderRetriever()
LeaderRetrievalService	StandaloneHaServices.getWebMonitorLeaderRetriever()

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	ZooKeeperHaServices.getDispatcherLeaderRetriever()
LeaderRetrievalService	ZooKeeperHaServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	ZooKeeperHaServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
LeaderRetrievalService	ZooKeeperHaServices.getResourceManagerLeaderRetriever()
LeaderRetrievalService	ZooKeeperHaServices.getWebMonitorLeaderRetriever()

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	SettableLeaderRetrievalService LeaderRetrievalService implementation which directly forwards calls of notifyListener to the listener.
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, scala.concurrent.duration.FiniteDuration timeout)
static InetAddress	LeaderRetrievalUtils.findConnectingAddress(LeaderRetrievalService leaderRetrievalService, Time timeout)
static LeaderConnectionInfo	LeaderRetrievalUtils.retrieveLeaderConnectionInfo(LeaderRetrievalService leaderRetrievalService, scala.concurrent.duration.FiniteDuration timeout) Retrieves the leader akka url and the current leader session ID.
static LeaderConnectionInfo	LeaderRetrievalUtils.retrieveLeaderConnectionInfo(LeaderRetrievalService leaderRetrievalService, Time timeout) Retrieves the leader akka url and the current leader session ID.
static ActorGateway	LeaderRetrievalUtils.retrieveLeaderGateway(LeaderRetrievalService leaderRetrievalService, akka.actor.ActorSystem actorSystem, scala.concurrent.duration.FiniteDuration timeout) Retrieves the current leader gateway using the given LeaderRetrievalService.
static UUID	LeaderRetrievalUtils.retrieveLeaderSessionId(LeaderRetrievalService leaderRetrievalService, scala.concurrent.duration.FiniteDuration timeout) Retrieves the current leader session id of the component identified by the given leader retrieval service.

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

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

Modifier and Type	Method and Description
LeaderRetrievalService	YarnPreConfiguredMasterNonHaServices.getDispatcherLeaderRetriever()
LeaderRetrievalService	YarnIntraNonHaMasterServices.getDispatcherLeaderRetriever()
LeaderRetrievalService	YarnPreConfiguredMasterNonHaServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	YarnIntraNonHaMasterServices.getJobManagerLeaderRetriever(JobID jobID)
LeaderRetrievalService	YarnPreConfiguredMasterNonHaServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
LeaderRetrievalService	YarnIntraNonHaMasterServices.getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress)
LeaderRetrievalService	YarnPreConfiguredMasterNonHaServices.getResourceManagerLeaderRetriever()
LeaderRetrievalService	YarnIntraNonHaMasterServices.getResourceManagerLeaderRetriever()
LeaderRetrievalService	YarnPreConfiguredMasterNonHaServices.getWebMonitorLeaderRetriever()
LeaderRetrievalService	YarnIntraNonHaMasterServices.getWebMonitorLeaderRetriever()