class

AWS::KCL::Checkpointer

Inherits Reference < Object

A checkpointer class which allows you to make checkpoint requests.

A checkpoint marks a point in a shard where you've successfully processed to. If this processor fails or loses its lease to that shard, another processor will be started either by this {https://github.com/awslabs/amazon-kinesis-client/blob/master/src/main/java/com/amazonaws/services/kinesis/multilang/package-info.java MultiLangDaemon} or a different instance and resume at the most recent checkpoint in this shard.

Instance methods

checkpoint(sequence_number : String | Nil) : Nil

Checkpoints at a particular sequence number you provide or if nil was passed, the checkpoint will be at the end of the most recently delivered list of records.

@param sequence_number [String, Nil] The sequence number to checkpoint at or nil if you want to checkpoint at the farthest record. @raise [CheckpointerException] if the {https://github.com/awslabs/amazon-kinesis-client/blob/master/src/main/java/com/amazonaws/services/kinesis/multilang/package-info.java MultiLangDaemon} returned a response indicating an error, or if the checkpointer encountered unexpected input.

Source