Interface DispatcherRunner
-
- All Superinterfaces:
AutoCloseable
,AutoCloseableAsync
- All Known Implementing Classes:
DefaultDispatcherRunner
public interface DispatcherRunner extends AutoCloseableAsync
TheDispatcherRunner
encapsulates how aDispatcher
is being executed.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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 finalApplicationStatus
once the runner wants to shut down.- Returns:
- future with the final application status
-
-