public class DispatcherResourceManagerComponent<T extends Dispatcher> extends Object implements AutoCloseableAsync
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
closeAsync()
Trigger the closing of the resource and return the corresponding
close future.
|
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() |
WebMonitorEndpoint<?> |
getWebMonitorEndpoint() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
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
public CompletableFuture<Void> closeAsync()
AutoCloseableAsync
closeAsync
in interface AutoCloseableAsync
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.