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) |
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, getClusterRestEndpointLeaderElectionService, getClusterRestEndpointLeaderRetriever, getDispatcherLeaderElectionService, getDispatcherLeaderRetriever, getJobManagerLeaderElectionService, getJobManagerLeaderRetriever, getJobManagerLeaderRetriever, getResourceManagerLeaderElectionService, getResourceManagerLeaderRetriever
checkNotShutdown, closeAndCleanupAllData, createBlobStore, getJobGraphStore, getRunningJobsRegistry, isShutDown
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
cleanupJobData, getWebMonitorLeaderElectionService, getWebMonitorLeaderRetriever
public EmbeddedHaServicesWithLeadershipControl(Executor executor)
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–2021 The Apache Software Foundation. All rights reserved.