public class EmbeddedHaServicesWithLeadershipControl extends EmbeddedHaServices implements HaLeadershipControl
EmbeddedHaServices
extension to expose leadership granting and revoking.lock
DEFAULT_JOB_ID, DEFAULT_LEADER_ID
Constructor and Description |
---|
EmbeddedHaServicesWithLeadershipControl(Executor executor) |
EmbeddedHaServicesWithLeadershipControl(Executor executor,
CheckpointRecoveryFactory checkpointRecoveryFactory) |
Modifier and Type | Method and Description |
---|---|
CheckpointRecoveryFactory |
getCheckpointRecoveryFactory()
Gets the checkpoint recovery factory for the job manager.
|
CompletableFuture<Void> |
grantDispatcherLeadership() |
CompletableFuture<Void> |
grantJobMasterLeadership(JobID jobId) |
CompletableFuture<Void> |
grantResourceManagerLeadership() |
CompletableFuture<Void> |
revokeDispatcherLeadership() |
CompletableFuture<Void> |
revokeJobMasterLeadership(JobID jobId) |
CompletableFuture<Void> |
revokeResourceManagerLeadership() |
close, getClusterRestEndpointLeaderElection, getClusterRestEndpointLeaderRetriever, getDispatcherLeaderElection, getDispatcherLeaderRetriever, getJobManagerLeaderElection, getJobManagerLeaderRetriever, getJobManagerLeaderRetriever, getResourceManagerLeaderElection, getResourceManagerLeaderRetriever
checkNotShutdown, cleanupAllData, createBlobStore, getJobGraphStore, getJobResultStore, isShutDown
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
closeWithOptionalClean, getWebMonitorLeaderElection, getWebMonitorLeaderRetriever, globalCleanupAsync
public EmbeddedHaServicesWithLeadershipControl(Executor executor)
public EmbeddedHaServicesWithLeadershipControl(Executor executor, CheckpointRecoveryFactory checkpointRecoveryFactory)
public CompletableFuture<Void> revokeDispatcherLeadership()
revokeDispatcherLeadership
in interface HaLeadershipControl
public CompletableFuture<Void> grantDispatcherLeadership()
grantDispatcherLeadership
in interface HaLeadershipControl
public CompletableFuture<Void> revokeJobMasterLeadership(JobID jobId)
revokeJobMasterLeadership
in interface HaLeadershipControl
public CompletableFuture<Void> grantJobMasterLeadership(JobID jobId)
grantJobMasterLeadership
in interface HaLeadershipControl
public CompletableFuture<Void> revokeResourceManagerLeadership()
revokeResourceManagerLeadership
in interface HaLeadershipControl
public CompletableFuture<Void> grantResourceManagerLeadership()
grantResourceManagerLeadership
in interface HaLeadershipControl
public CheckpointRecoveryFactory getCheckpointRecoveryFactory()
HighAvailabilityServices
getCheckpointRecoveryFactory
in interface HighAvailabilityServices
getCheckpointRecoveryFactory
in class AbstractNonHaServices
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.