org.apache.flink.runtime.dispatcher.runner

Interface DispatcherRunner

All Superinterfaces:

AutoCloseable, AutoCloseableAsync

All Known Implementing Classes:

DefaultDispatcherRunner

public interface DispatcherRunner
extends AutoCloseableAsync

The DispatcherRunner encapsulates how a Dispatcher is being executed.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<ApplicationStatus>	getShutDownFuture() Return shut down future of this runner.

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

close, closeAsync

Method Detail

getShutDownFuture

CompletableFuture<ApplicationStatus> getShutDownFuture()

Return shut down future of this runner. The shut down future is being completed with the final ApplicationStatus once the runner wants to shut down.

Returns:

future with the final application status