org.apache.flink.runtime.rest.handler.legacy

Class JobCancellationWithSavepointHandlers

java.lang.Object

org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers

public class JobCancellationWithSavepointHandlers
extends Object

Request handler for JobManagerMessages.CancelJobWithSavepoint messages.

Constructor Summary

Constructors

Constructor and Description
JobCancellationWithSavepointHandlers(ExecutionGraphCache currentGraphs, Executor executor)
JobCancellationWithSavepointHandlers(ExecutionGraphCache currentGraphs, Executor executor, String defaultSavepointDirectory)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers.InProgressHandler	getInProgressHandler()
org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers.TriggerHandler	getTriggerHandler()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobCancellationWithSavepointHandlers

public JobCancellationWithSavepointHandlers(ExecutionGraphCache currentGraphs,
                                            Executor executor)

JobCancellationWithSavepointHandlers

public JobCancellationWithSavepointHandlers(ExecutionGraphCache currentGraphs,
                                            Executor executor,
                                            @Nullable
                                            String defaultSavepointDirectory)

Method Detail

getTriggerHandler

public org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers.TriggerHandler getTriggerHandler()

getInProgressHandler

public org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers.InProgressHandler getInProgressHandler()