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<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) |
Modifier and Type | Method and Description |
---|---|
static <R extends Serializable> |
OperationResult.failure(Throwable throwable) |
static <R extends Serializable> |
OperationResult.inProgress() |
static <R extends Serializable> |
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<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.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.