public class JobCancellationWithSavepointHandlers extends Object
JobManagerMessages.CancelJobWithSavepoint
messages.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 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–2018 The Apache Software Foundation. All rights reserved.