presto-kinesis/src/main/java/io/prestosql/plugin/kinesis/KinesisRecordSet.java/KinesisRecordCursor/getCompletedBytes
class KinesisRecordCursor:        @Override
        public long getCompletedBytes()
        {
            return totalBytes;
        }