public class JobCancellationWithSavepointHandlers extends Object
JobManagerMessages.CancelJobWithSavepoint
messages.Modifier and Type | Field and Description |
---|---|
static String |
IN_PROGRESS_URL
URL for in-progress cancellations.
|
Constructor and Description |
---|
JobCancellationWithSavepointHandlers(ExecutionGraphHolder currentGraphs,
scala.concurrent.ExecutionContext executionContext) |
JobCancellationWithSavepointHandlers(ExecutionGraphHolder currentGraphs,
scala.concurrent.ExecutionContext executionContext,
String defaultSavepointDirectory) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.InProgressHandler |
getInProgressHandler() |
org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.TriggerHandler |
getTriggerHandler() |
public static final String IN_PROGRESS_URL
public JobCancellationWithSavepointHandlers(ExecutionGraphHolder currentGraphs, scala.concurrent.ExecutionContext executionContext)
public JobCancellationWithSavepointHandlers(ExecutionGraphHolder currentGraphs, scala.concurrent.ExecutionContext executionContext, @Nullable String defaultSavepointDirectory)
public org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.TriggerHandler getTriggerHandler()
public org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.InProgressHandler getInProgressHandler()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.