Interface ResourceManagerService
-
- All Superinterfaces:
AutoCloseable
,AutoCloseableAsync
- All Known Implementing Classes:
ResourceManagerServiceImpl
public interface ResourceManagerService extends AutoCloseableAsync
Service that maintains lifecycle ofResourceManager
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CompletableFuture<Void>
deregisterApplication(ApplicationStatus applicationStatus, String diagnostics)
Deregister the Flink application from the resource management system by signalling theResourceManager
.CompletableFuture<Void>
getTerminationFuture()
Return termination future of the service.void
start()
Start the service.-
Methods inherited from interface org.apache.flink.util.AutoCloseableAsync
close, closeAsync
-
-
-
-
Method Detail
-
start
void start() throws Exception
Start the service.- Throws:
Exception
- if the service cannot be started
-
getTerminationFuture
CompletableFuture<Void> getTerminationFuture()
Return termination future of the service.- Returns:
- termination future of the service.
-
deregisterApplication
CompletableFuture<Void> deregisterApplication(ApplicationStatus applicationStatus, @Nullable String diagnostics)
Deregister the Flink application from the resource management system by signalling theResourceManager
.- Parameters:
applicationStatus
- to terminate the application withdiagnostics
- additional information about the shut down, can benull
- Returns:
- Future which is completed once the shut down
-
-