org.apache.flink.runtime.dispatcher.runner

Class DefaultDispatcherGatewayService

java.lang.Object

org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherGatewayService

All Implemented Interfaces:

AutoCloseable, AbstractDispatcherLeaderProcess.DispatcherGatewayService, AutoCloseableAsync

@Internal
public class DefaultDispatcherGatewayService
extends Object
implements AbstractDispatcherLeaderProcess.DispatcherGatewayService

A facade over the Dispatcher that exposes specific functionality.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
static DefaultDispatcherGatewayService	from(Dispatcher dispatcher)
DispatcherGateway	getGateway()
CompletableFuture<ApplicationStatus>	getShutDownFuture()
CompletableFuture<Void>	getTerminationFuture()
CompletableFuture<Void>	onRemovedJobGraph(JobID jobId)

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

Method Detail

getGateway

public DispatcherGateway getGateway()

Specified by:

getGateway in interface AbstractDispatcherLeaderProcess.DispatcherGatewayService

onRemovedJobGraph

public CompletableFuture<Void> onRemovedJobGraph(JobID jobId)

Specified by:

onRemovedJobGraph in interface AbstractDispatcherLeaderProcess.DispatcherGatewayService

getShutDownFuture

public CompletableFuture<ApplicationStatus> getShutDownFuture()

Specified by:

getShutDownFuture in interface AbstractDispatcherLeaderProcess.DispatcherGatewayService

getTerminationFuture

public CompletableFuture<Void> getTerminationFuture()

Specified by:

getTerminationFuture in interface AbstractDispatcherLeaderProcess.DispatcherGatewayService

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

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

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed

from

public static DefaultDispatcherGatewayService from(Dispatcher dispatcher)