Modifier and Type | Method and Description |
---|---|
CompletedOperationCache<AsynchronousJobOperationKey,String> |
DispatcherOperationCaches.getSavepointTriggerCache() |
Modifier and Type | Method and Description |
---|---|
static AsynchronousJobOperationKey |
AsynchronousJobOperationKey.of(TriggerId triggerId,
JobID jobId) |
Modifier and Type | Method and Description |
---|---|
protected AsynchronousJobOperationKey |
RescalingHandlers.RescalingTriggerHandler.createOperationKey(HandlerRequest<EmptyRequestBody> request) |
protected AsynchronousJobOperationKey |
RescalingHandlers.RescalingStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody> request) |
Modifier and Type | Method and Description |
---|---|
protected AsynchronousJobOperationKey |
SavepointHandlers.SavepointStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody> request) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<Acknowledge> |
SavepointHandlers.SavepointTriggerHandler.triggerOperation(HandlerRequest<SavepointTriggerRequestBody> request,
AsynchronousJobOperationKey operationKey,
RestfulGateway gateway) |
protected CompletableFuture<Acknowledge> |
SavepointHandlers.StopWithSavepointHandler.triggerOperation(HandlerRequest<StopWithSavepointRequestBody> request,
AsynchronousJobOperationKey operationKey,
RestfulGateway gateway) |
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.
|
default CompletableFuture<Acknowledge> |
RestfulGateway.stopWithSavepoint(AsynchronousJobOperationKey operationKey,
String targetDirectory,
SavepointFormatType formatType,
TriggerSavepointMode savepointMode,
Time timeout)
Stops the job with a savepoint, returning a future that completes when the operation is
started.
|
default CompletableFuture<Acknowledge> |
RestfulGateway.triggerSavepoint(AsynchronousJobOperationKey operationKey,
String targetDirectory,
SavepointFormatType formatType,
TriggerSavepointMode savepointMode,
Time timeout)
Triggers a savepoint with the given savepoint directory as a target, returning a future that
completes when the operation is started.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.