org.apache.flink.runtime.dispatcher.runner

Class AbstractDispatcherLeaderProcess

java.lang.Object

org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess

Direct Known Subclasses:

JobDispatcherLeaderProcess, SessionDispatcherLeaderProcess

@Internal
public abstract class AbstractDispatcherLeaderProcess
extends Object

A base DispatcherLeaderProcess.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AbstractDispatcherLeaderProcess.DispatcherGatewayService An accessor of the DispatcherGateway.
static interface	AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory Factory for AbstractDispatcherLeaderProcess.DispatcherGatewayService.
protected static class	AbstractDispatcherLeaderProcess.State The state of the DispatcherLeaderProcess.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
CompletableFuture<DispatcherGateway>	getDispatcherGateway()
protected Optional<AbstractDispatcherLeaderProcess.DispatcherGatewayService>	getDispatcherService()
CompletableFuture<String>	getLeaderAddressFuture()
UUID	getLeaderSessionId()
CompletableFuture<ApplicationStatus>	getShutDownFuture()
protected CompletableFuture<Void>	onClose()
protected abstract void	onStart()
void	start()

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.util.AutoCloseableAsync

close

Field Detail

log

protected final org.slf4j.Logger log

Method Detail

start

public final void start()

getLeaderSessionId

public final UUID getLeaderSessionId()

getDispatcherGateway

public final CompletableFuture<DispatcherGateway> getDispatcherGateway()

getLeaderAddressFuture

public final CompletableFuture<String> getLeaderAddressFuture()

getShutDownFuture

public CompletableFuture<ApplicationStatus> getShutDownFuture()

getDispatcherService

protected final Optional<AbstractDispatcherLeaderProcess.DispatcherGatewayService> getDispatcherService()

closeAsync

public final CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Returns:

Future which is completed once the resource has been closed

onStart

protected abstract void onStart()

onClose

protected CompletableFuture<Void> onClose()