Package org.apache.flink.runtime.dispatcher.runner

Interface AbstractDispatcherLeaderProcess.DispatcherGatewayService

All Superinterfaces:

AutoCloseable, AutoCloseableAsync

All Known Implementing Classes:

DefaultDispatcherGatewayService

Enclosing class:

AbstractDispatcherLeaderProcess

public static interface AbstractDispatcherLeaderProcess.DispatcherGatewayService
extends AutoCloseableAsync

An accessor of the DispatcherGateway.

Method Summary

Modifier and Type	Method	Description
DispatcherGateway	getGateway()
CompletableFuture<ApplicationStatus>	getShutDownFuture()
CompletableFuture<Void>	getTerminationFuture()
CompletableFuture<Void>	onRemovedExecutionPlan(JobID jobId)

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close, closeAsync

Method Detail

getGateway

DispatcherGateway getGateway()

onRemovedExecutionPlan

CompletableFuture<Void> onRemovedExecutionPlan(JobID jobId)

getShutDownFuture

CompletableFuture<ApplicationStatus> getShutDownFuture()

getTerminationFuture

CompletableFuture<Void> getTerminationFuture()