org.apache.flink.runtime.rest.messages.checkpoints

Class CheckpointTriggerRequestBody

java.lang.Object

org.apache.flink.runtime.rest.messages.checkpoints.CheckpointTriggerRequestBody

All Implemented Interfaces:

RequestBody

public class CheckpointTriggerRequestBody
extends Object
implements RequestBody

RequestBody to trigger checkpoints.

Constructor Summary

Constructors

Constructor and Description
CheckpointTriggerRequestBody(CheckpointType checkpointType, TriggerId triggerId)

Method Summary

Modifier and Type	Method and Description
CheckpointType	getCheckpointType()
Optional<TriggerId>	getTriggerId()

Methods inherited from class java.lang.Object

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

Constructor Detail

CheckpointTriggerRequestBody

public CheckpointTriggerRequestBody(@Nullable
                                    CheckpointType checkpointType,
                                    @Nullable
                                    TriggerId triggerId)

Method Detail

getTriggerId

public Optional<TriggerId> getTriggerId()

getCheckpointType

public CheckpointType getCheckpointType()