Checkpoint Class

Contains checkpoint metadata.

Inheritance
builtins.object
Checkpoint

Constructor

Checkpoint(partition_id, offset='-1', sequence_number='0')

Methods

from_source

Creates a new Checkpoint from an existing checkpoint.

from_source

Creates a new Checkpoint from an existing checkpoint.

from_source(checkpoint)

Parameters

checkpoint
Checkpoint
Required

Existing checkpoint.