public class JobDispatcherLeaderProcess extends Object
DispatcherLeaderProcess
implementation for the per-job mode.Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractDispatcherLeaderProcess.State
The state of the
DispatcherLeaderProcess . |
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
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<org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayService> |
getDispatcherService() |
CompletableFuture<String> |
getLeaderAddressFuture() |
UUID |
getLeaderSessionId() |
CompletableFuture<ApplicationStatus> |
getShutDownFuture() |
protected CompletableFuture<Void> |
onClose() |
protected void |
onStart() |
void |
start() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
protected void onStart()
public final void start()
public final UUID getLeaderSessionId()
public final CompletableFuture<DispatcherGateway> getDispatcherGateway()
public final CompletableFuture<String> getLeaderAddressFuture()
public CompletableFuture<ApplicationStatus> getShutDownFuture()
protected final Optional<org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayService> getDispatcherService()
public final CompletableFuture<Void> closeAsync()
AutoCloseableAsync
protected CompletableFuture<Void> onClose()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.