public class DispatcherResourceManagerComponent<T extends Dispatcher> extends Object
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
deregisterApplicationAndClose(ApplicationStatus applicationStatus,
String diagnostics)
Deregister the Flink application from the resource management system by signalling
the
ResourceManager . |
T |
getDispatcher() |
CompletableFuture<ApplicationStatus> |
getShutDownFuture() |
CompletableFuture<Void> |
getTerminationFuture() |
WebMonitorEndpoint<?> |
getWebMonitorEndpoint() |
public CompletableFuture<Void> getTerminationFuture()
public final CompletableFuture<ApplicationStatus> getShutDownFuture()
@Nonnull public WebMonitorEndpoint<?> getWebMonitorEndpoint()
public CompletableFuture<Void> deregisterApplicationAndClose(ApplicationStatus applicationStatus, @Nullable String diagnostics)
ResourceManager
.applicationStatus
- to terminate the application withdiagnostics
- additional information about the shut down, can be null
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.