presto-kinesis/src/main/java/io/prestosql/plugin/kinesis/KinesisShardCheckpointer.java/KinesisShardCheckpointer/checkpoint
class KinesisShardCheckpointer:    public void checkpoint(String lastReadSequenceNumber)
    {
        log.info("Trying to checkpoint at " + lastReadSequenceNumber);
        try {
            ExtendedSequenceNumber esn = new ExtendedSequenceNumber(lastReadSequenceNumber);
            kinesisClientLease.setCheckpoint(esn);
            leaseManager.createLeaseIfNotExists(kinesisClientLease);
            if (!leaseManager.updateLease(kinesisClientLease)) {
                log.warn("Checkpointing unsuccessful");
            }
        }
        catch (DependencyException | InvalidStateException | ProvisionedThroughputException e) {
            throwIfUnchecked(e);
            throw new RuntimeException(e);
        }
        resetNextCheckpointTime();
    }