public interface StopWithSavepointTerminationHandler
StopWithSavepointTerminationHandlerhandles the steps necessary for the stop-with-savepoint operation to finish. The order of the operations matter:
|Modifier and Type||Method and Description|
Returns the a
Handles the termination of the job based on the passed terminated
Handles the result of a
CompletableFuturereferring to the result of the stop-with-savepoint operation.
CompletableFuturecontaining the path to the created savepoint in case of success.
void handleSavepointCreation(@Nullable CompletedCheckpoint completedSavepoint, @Nullable Throwable throwable)
CompletedCheckpoint. Only one of the two parameters are allowed to be set.
CompletedCheckpointreferring to the created savepoint
throwable- an error that was caught during savepoint creation
NullPointerException- if none of the parameters is set
void handleExecutionsTermination(Collection<ExecutionState> terminatedExecutionStates)
ExecutionStates. stop-with-savepoint expects the
terminatedExecutionStatesto only contain
terminatedExecutionStates- The terminated
ExecutionStatesof the underlying job.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.