Uses of Interface
org.apache.flink.runtime.leaderelection.LeaderElectionService

Packages that use LeaderElectionService

Package	Description
org.apache.flink.kubernetes.highavailability
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.runner
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.jobmaster
org.apache.flink.runtime.leaderelection
org.apache.flink.runtime.rest
org.apache.flink.runtime.webmonitor

Uses of LeaderElectionService in org.apache.flink.kubernetes.highavailability

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

Modifier and Type	Method and Description
LeaderElectionService	KubernetesHaServices.createLeaderElectionService(String leaderName) Deprecated.
protected LeaderElectionService	KubernetesMultipleComponentLeaderElectionHaServices.createLeaderElectionService(String leaderName)

Uses of LeaderElectionService in org.apache.flink.runtime.dispatcher

Constructors in org.apache.flink.runtime.dispatcher with parameters of type LeaderElectionService

Constructor and Description

DispatcherRestEndpoint(GatewayRetriever<DispatcherGateway> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)

Uses of LeaderElectionService in org.apache.flink.runtime.dispatcher.runner

Methods in org.apache.flink.runtime.dispatcher.runner with parameters of type LeaderElectionService

Modifier and Type	Method and Description
static DispatcherRunner	DefaultDispatcherRunner.create(LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler, DispatcherLeaderProcessFactory dispatcherLeaderProcessFactory)
DispatcherRunner	DefaultDispatcherRunnerFactory.createDispatcherRunner(LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler, JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices)
DispatcherRunner	DispatcherRunnerFactory.createDispatcherRunner(LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler, JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices)

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

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

Modifier and Type	Method and Description
protected abstract LeaderElectionService	AbstractHaServices.createLeaderElectionService(String leaderName) Create leader election service with specified leaderName.
LeaderElectionService	AbstractHaServices.getClusterRestEndpointLeaderElectionService()
default LeaderElectionService	HighAvailabilityServices.getClusterRestEndpointLeaderElectionService() Gets the leader election service for the cluster's rest endpoint.
LeaderElectionService	AbstractHaServices.getDispatcherLeaderElectionService()
LeaderElectionService	HighAvailabilityServices.getDispatcherLeaderElectionService() Gets the leader election service for the cluster's dispatcher.
LeaderElectionService	AbstractHaServices.getJobManagerLeaderElectionService(JobID jobID)
LeaderElectionService	HighAvailabilityServices.getJobManagerLeaderElectionService(JobID jobID) Gets the leader election service for the given job.
LeaderElectionService	AbstractHaServices.getResourceManagerLeaderElectionService()
LeaderElectionService	HighAvailabilityServices.getResourceManagerLeaderElectionService() Gets the leader election service for the cluster's resource manager.
default LeaderElectionService	HighAvailabilityServices.getWebMonitorLeaderElectionService() Deprecated. Use HighAvailabilityServices.getClusterRestEndpointLeaderElectionService() instead.

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

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

Modifier and Type	Method and Description
LeaderElectionService	EmbeddedLeaderService.createLeaderElectionService()
LeaderElectionService	EmbeddedHaServices.getClusterRestEndpointLeaderElectionService()
LeaderElectionService	EmbeddedHaServices.getDispatcherLeaderElectionService()
LeaderElectionService	EmbeddedHaServices.getJobManagerLeaderElectionService(JobID jobID)
LeaderElectionService	EmbeddedHaServices.getResourceManagerLeaderElectionService()

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

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

Modifier and Type	Method and Description
LeaderElectionService	StandaloneHaServices.getClusterRestEndpointLeaderElectionService()
LeaderElectionService	StandaloneHaServices.getDispatcherLeaderElectionService()
LeaderElectionService	StandaloneHaServices.getJobManagerLeaderElectionService(JobID jobID)
LeaderElectionService	StandaloneHaServices.getResourceManagerLeaderElectionService()

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

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

Modifier and Type	Method and Description
protected LeaderElectionService	ZooKeeperMultipleComponentLeaderElectionHaServices.createLeaderElectionService(String leaderName)
protected LeaderElectionService	ZooKeeperHaServices.createLeaderElectionService(String leaderPath) Deprecated.

Uses of LeaderElectionService in org.apache.flink.runtime.jobmaster

Constructors in org.apache.flink.runtime.jobmaster with parameters of type LeaderElectionService

Constructor and Description
JobMasterServiceLeadershipRunner(JobMasterServiceProcessFactory jobMasterServiceProcessFactory, LeaderElectionService leaderElectionService, JobResultStore jobResultStore, LibraryCacheManager.ClassLoaderLease classLoaderLease, FatalErrorHandler fatalErrorHandler)
MiniDispatcherRestEndpoint(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)

Uses of LeaderElectionService in org.apache.flink.runtime.leaderelection

Classes in org.apache.flink.runtime.leaderelection that implement LeaderElectionService

Modifier and Type	Class and Description
class	DefaultLeaderElectionService Default implementation for leader election service.
class	StandaloneLeaderElectionService Standalone implementation of the LeaderElectionService interface.

Uses of LeaderElectionService in org.apache.flink.runtime.rest

Methods in org.apache.flink.runtime.rest with parameters of type LeaderElectionService

Modifier and Type	Method and Description
WebMonitorEndpoint<DispatcherGateway>	SessionRestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)
WebMonitorEndpoint<RestfulGateway>	JobRestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)
WebMonitorEndpoint<T>	RestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)

Uses of LeaderElectionService in org.apache.flink.runtime.webmonitor

Constructors in org.apache.flink.runtime.webmonitor with parameters of type LeaderElectionService

Constructor and Description

WebMonitorEndpoint(GatewayRetriever<? extends T> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)