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 and Description
CompletableFuture<OperationResult<Long>>	getCheckpointStatus(AsynchronousJobOperationKey operationKey)
CompletableFuture<OperationResult<String>>	getSavepointStatus(AsynchronousJobOperationKey operationKey)
CompletableFuture<Acknowledge>	stopWithSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time timeout)
CompletableFuture<Acknowledge>	triggerCheckpoint(AsynchronousJobOperationKey operationKey, CheckpointType checkpointType, Time timeout)
CompletableFuture<Acknowledge>	triggerSavepoint(AsynchronousJobOperationKey operationKey, String targetDirectory, SavepointFormatType formatType, TriggerSavepointMode savepointMode, Time 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,
                                                        Time timeout)

getCheckpointStatus

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

triggerSavepoint

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

stopWithSavepoint

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

getSavepointStatus

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