Package org.apache.flink.runtime.dispatcher

Class DispatcherCachedOperationsHandler

java.lang.Object

org.apache.flink.runtime.dispatcher.DispatcherCachedOperationsHandler

public class DispatcherCachedOperationsHandler
extends Object

A handler for async operations triggered by the Dispatcher whose keys and results are cached.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<OperationResult<Long>>	getCheckpointStatus(AsynchronousJobOperationKey operationKey)
CompletableFuture<OperationResult<String>>	getSavepointStatus(AsynchronousJobOperationKey operationKey)
CompletableFuture<Acknowledge>	stopWithSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Duration timeout)
CompletableFuture<Acknowledge>	triggerCheckpoint(AsynchronousJobOperationKey operationKey, CheckpointType checkpointType, Duration timeout)
CompletableFuture<Acknowledge>	triggerSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Duration timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

triggerCheckpoint

public CompletableFuture<Acknowledge> triggerCheckpoint(AsynchronousJobOperationKey operationKey,
                                                        CheckpointType checkpointType,
                                                        Duration timeout)

getCheckpointStatus

public CompletableFuture<OperationResult<Long>> getCheckpointStatus(AsynchronousJobOperationKey operationKey)

triggerSavepoint

public CompletableFuture<Acknowledge> triggerSavepoint(AsynchronousJobOperationKey operationKey,
                                                       String targetDirectory,
                                                       SavepointFormatType formatType,
                                                       TriggerSavepointMode savepointMode,
                                                       Duration timeout)

stopWithSavepoint

public CompletableFuture<Acknowledge> stopWithSavepoint(AsynchronousJobOperationKey operationKey,
                                                        String targetDirectory,
                                                        SavepointFormatType formatType,
                                                        TriggerSavepointMode savepointMode,
                                                        Duration timeout)

getSavepointStatus

public CompletableFuture<OperationResult<String>> getSavepointStatus(AsynchronousJobOperationKey operationKey)