org.apache.flink.runtime.highavailability.nonha.embedded

Class EmbeddedHaServicesWithLeadershipControl

java.lang.Object

org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices

org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServices

org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl

All Implemented Interfaces:

AutoCloseable, ClientHighAvailabilityServices, HighAvailabilityServices, HaLeadershipControl

public class EmbeddedHaServicesWithLeadershipControl
extends EmbeddedHaServices
implements HaLeadershipControl

EmbeddedHaServices extension to expose leadership granting and revoking.

Field Summary

Fields inherited from class org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices

lock

Fields inherited from interface org.apache.flink.runtime.highavailability.HighAvailabilityServices

DEFAULT_JOB_ID, DEFAULT_LEADER_ID

Constructor Summary

Constructors

Constructor and Description
EmbeddedHaServicesWithLeadershipControl(Executor executor)
EmbeddedHaServicesWithLeadershipControl(Executor executor, CheckpointRecoveryFactory checkpointRecoveryFactory)

Method Summary

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()

Methods inherited from class org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServices

close, getClusterRestEndpointLeaderElectionService, getClusterRestEndpointLeaderRetriever, getDispatcherLeaderElectionService, getDispatcherLeaderRetriever, getJobManagerLeaderElectionService, getJobManagerLeaderRetriever, getJobManagerLeaderRetriever, getResourceManagerLeaderElectionService, getResourceManagerLeaderRetriever

Methods inherited from class org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices

checkNotShutdown, closeAndCleanupAllData, createBlobStore, getJobGraphStore, getRunningJobsRegistry, isShutDown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.highavailability.HighAvailabilityServices

cleanupJobData, getWebMonitorLeaderElectionService, getWebMonitorLeaderRetriever

Constructor Detail

EmbeddedHaServicesWithLeadershipControl

public EmbeddedHaServicesWithLeadershipControl(Executor executor)

EmbeddedHaServicesWithLeadershipControl

public EmbeddedHaServicesWithLeadershipControl(Executor executor,
                                               CheckpointRecoveryFactory checkpointRecoveryFactory)

Method Detail

revokeDispatcherLeadership

public CompletableFuture<Void> revokeDispatcherLeadership()

Specified by:

revokeDispatcherLeadership in interface HaLeadershipControl

grantDispatcherLeadership

public CompletableFuture<Void> grantDispatcherLeadership()

Specified by:

grantDispatcherLeadership in interface HaLeadershipControl

revokeJobMasterLeadership

public CompletableFuture<Void> revokeJobMasterLeadership(JobID jobId)

Specified by:

revokeJobMasterLeadership in interface HaLeadershipControl

grantJobMasterLeadership

public CompletableFuture<Void> grantJobMasterLeadership(JobID jobId)

Specified by:

grantJobMasterLeadership in interface HaLeadershipControl

revokeResourceManagerLeadership

public CompletableFuture<Void> revokeResourceManagerLeadership()

Specified by:

revokeResourceManagerLeadership in interface HaLeadershipControl

grantResourceManagerLeadership

public CompletableFuture<Void> grantResourceManagerLeadership()

Specified by:

grantResourceManagerLeadership in interface HaLeadershipControl

getCheckpointRecoveryFactory

public CheckpointRecoveryFactory getCheckpointRecoveryFactory()

Description copied from interface: HighAvailabilityServices

Gets the checkpoint recovery factory for the job manager.

Specified by:

getCheckpointRecoveryFactory in interface HighAvailabilityServices

Overrides:

getCheckpointRecoveryFactory in class AbstractNonHaServices

Returns:

Checkpoint recovery factory