Package | Description |
---|---|
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.rest.handler.async | |
org.apache.flink.runtime.webmonitor |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<OperationResult<String>> |
DispatcherCachedOperationsHandler.getSavepointStatus(AsynchronousJobOperationKey operationKey) |
CompletableFuture<OperationResult<String>> |
Dispatcher.getTriggeredSavepointStatus(AsynchronousJobOperationKey operationKey) |
Modifier and Type | Method and Description |
---|---|
static <R> OperationResult<R> |
OperationResult.failure(Throwable throwable) |
static <R> OperationResult<R> |
OperationResult.inProgress() |
static <R> OperationResult<R> |
OperationResult.success(R result) |
Modifier and Type | Method and Description |
---|---|
Optional<OperationResult<R>> |
CompletedOperationCache.get(K operationKey)
Returns an optional containing the
OperationResult for the specified key, or an empty
optional if no operation is registered under the key. |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<OperationResult<String>> |
RestfulGateway.getTriggeredSavepointStatus(AsynchronousJobOperationKey operationKey)
Get the status of a savepoint triggered under the specified operation key.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.