Uses of Class
org.apache.flink.runtime.rest.handler.async.OperationResult
-
Packages that use OperationResult Package Description org.apache.flink.runtime.dispatcher org.apache.flink.runtime.rest.handler.async org.apache.flink.runtime.webmonitor -
-
Uses of OperationResult in org.apache.flink.runtime.dispatcher
Methods in org.apache.flink.runtime.dispatcher that return types with arguments of type OperationResult Modifier and Type Method Description CompletableFuture<OperationResult<Long>>
DispatcherCachedOperationsHandler. getCheckpointStatus(AsynchronousJobOperationKey operationKey)
CompletableFuture<OperationResult<String>>
DispatcherCachedOperationsHandler. getSavepointStatus(AsynchronousJobOperationKey operationKey)
CompletableFuture<OperationResult<Long>>
Dispatcher. getTriggeredCheckpointStatus(AsynchronousJobOperationKey operationKey)
CompletableFuture<OperationResult<String>>
Dispatcher. getTriggeredSavepointStatus(AsynchronousJobOperationKey operationKey)
-
Uses of OperationResult in org.apache.flink.runtime.rest.handler.async
Methods in org.apache.flink.runtime.rest.handler.async that return OperationResult Modifier and Type Method Description static <R extends Serializable>
OperationResult<R>OperationResult. failure(Throwable throwable)
static <R extends Serializable>
OperationResult<R>OperationResult. inProgress()
static <R extends Serializable>
OperationResult<R>OperationResult. success(R result)
Methods in org.apache.flink.runtime.rest.handler.async that return types with arguments of type OperationResult Modifier and Type Method Description Optional<OperationResult<R>>
CompletedOperationCache. get(K operationKey)
Returns an optional containing theOperationResult
for the specified key, or an empty optional if no operation is registered under the key. -
Uses of OperationResult in org.apache.flink.runtime.webmonitor
Methods in org.apache.flink.runtime.webmonitor that return types with arguments of type OperationResult Modifier and Type Method Description default CompletableFuture<OperationResult<Long>>
RestfulGateway. getTriggeredCheckpointStatus(AsynchronousJobOperationKey operationKey)
Get the status of a checkpoint triggered under the specified operation key.default CompletableFuture<OperationResult<String>>
RestfulGateway. getTriggeredSavepointStatus(AsynchronousJobOperationKey operationKey)
Get the status of a savepoint triggered under the specified operation key.
-