presto-kinesis/src/main/java/io/prestosql/plugin/kinesis/KinesisShardCheckpointer.java/KinesisShardCheckpointer/checkpointIfTimeUp
class KinesisShardCheckpointer:    public void checkpointIfTimeUp(String lastReadSeqNo)
    {
        if (System.nanoTime() >= nextCheckpointTimeMillis) {
            checkpoint(lastReadSeqNo);
        }
    }