Class: Aws::KCLrb::Checkpointer Abstract

Inherits:

Object

• Object
• Aws::KCLrb::Checkpointer

Defined in:

lib/aws/kclrb/checkpointer.rb

Overview

This class is abstract.

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 MultiLangDaemon or a different instance and resume at the most recent checkpoint in this shard.

Instance Method Summary

• #checkpoint(sequence_number = nil) ⇒ Object

  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.

Instance Method Details

#checkpoint(sequence_number = nil) ⇒ Object

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.

Parameters:

• sequence_number (String, nil) (defaults to: nil) —

  The sequence number to checkpoint at or nil if you want to checkpoint at the farthest record.

Raises:

• (CheckpointError) —

  if the MultiLangDaemon returned a response indicating an error, or if the checkpointer encountered unexpected input.

# File 'lib/aws/kclrb/checkpointer.rb', line 61

def checkpoint(sequence_number=nil)
  fail NotImplementedError.new
end