Class SavepointTriggerRequestBody
- java.lang.Object
-
- org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
-
- All Implemented Interfaces:
org.apache.flink.runtime.rest.messages.RequestBody
public class SavepointTriggerRequestBody extends java.lang.Object implements org.apache.flink.runtime.rest.messages.RequestBody
RequestBody
to trigger savepoints.
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
FIELD_NAME_TARGET_DIRECTORY
-
Constructor Summary
Constructors Constructor Description SavepointTriggerRequestBody(java.lang.String targetDirectory, java.lang.Boolean cancelJob, org.apache.flink.core.execution.SavepointFormatType formatType, org.apache.flink.runtime.rest.messages.TriggerId triggerId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.core.execution.SavepointFormatType
getFormatType()
java.util.Optional<java.lang.String>
getTargetDirectory()
java.util.Optional<org.apache.flink.runtime.rest.messages.TriggerId>
getTriggerId()
boolean
isCancelJob()
-
-
-
Field Detail
-
FIELD_NAME_TARGET_DIRECTORY
public static final java.lang.String FIELD_NAME_TARGET_DIRECTORY
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
SavepointTriggerRequestBody
public SavepointTriggerRequestBody(@Nullable java.lang.String targetDirectory, @Nullable java.lang.Boolean cancelJob, @Nullable org.apache.flink.core.execution.SavepointFormatType formatType, @Nullable org.apache.flink.runtime.rest.messages.TriggerId triggerId)
-
-
Method Detail
-
getTargetDirectory
public java.util.Optional<java.lang.String> getTargetDirectory()
-
getTriggerId
public java.util.Optional<org.apache.flink.runtime.rest.messages.TriggerId> getTriggerId()
-
isCancelJob
public boolean isCancelJob()
-
getFormatType
public org.apache.flink.core.execution.SavepointFormatType getFormatType()
-
-