presto-kinesis/src/main/java/io/prestosql/plugin/kinesis/KinesisRecordSet.java/KinesisRecordSet/shouldGetMoreRecords
class KinesisRecordSet:        private boolean shouldGetMoreRecords()
        {
            return shardIterator != null && batchesRead < maxBatches && getMillisBehindLatest() > MILLIS_BEHIND_LIMIT;
        }