Uses of Interface
org.apache.flink.runtime.resourcemanager.JobLeaderIdService

Packages that use JobLeaderIdService

Package	Description
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.active

Uses of JobLeaderIdService in org.apache.flink.runtime.resourcemanager

Classes in org.apache.flink.runtime.resourcemanager that implement JobLeaderIdService

Modifier and Type	Class and Description
class	DefaultJobLeaderIdService Service which retrieves for a registered job the current job leader id (the leader id of the job manager responsible for the job).

Methods in org.apache.flink.runtime.resourcemanager that return JobLeaderIdService

Modifier and Type	Method and Description
JobLeaderIdService	ResourceManagerRuntimeServices.getJobLeaderIdService()

Constructors in org.apache.flink.runtime.resourcemanager with parameters of type JobLeaderIdService

Constructor and Description
ResourceManager(RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, BlocklistHandler.Factory blocklistHandlerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, Time rpcTimeout, Executor ioExecutor)
ResourceManagerRuntimeServices(SlotManager slotManager, JobLeaderIdService jobLeaderIdService)
StandaloneResourceManager(RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, BlocklistHandler.Factory blocklistHandlerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, Time startupPeriodTime, Time rpcTimeout, Executor ioExecutor)

Uses of JobLeaderIdService in org.apache.flink.runtime.resourcemanager.active

Constructors in org.apache.flink.runtime.resourcemanager.active with parameters of type JobLeaderIdService

Constructor and Description

ActiveResourceManager(ResourceManagerDriver<WorkerType> resourceManagerDriver, Configuration flinkConfig, RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, BlocklistHandler.Factory blocklistHandlerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, ThresholdMeter startWorkerFailureRater, java.time.Duration retryInterval, java.time.Duration workerRegistrationTimeout, java.time.Duration previousWorkerRecoverTimeout, Executor ioExecutor)