library/src/main/java/com/kdgregory/aws/utils/kinesis/KinesisReader.java
/**
         *  Returns the next record from the stream. Note that records read from
         *  different shards may not be read in the order they were written.
         */
Returns the next record from the stream. Note that records read from
different shards may not be read in the order they were written.
Returns the next record from the stream . Note that records read from different shards may not be read in the order they were written .
@Override
        public Record next()
        {
            if (! hasNext())
                throw new NoSuchElementException("no more records for this iteration of " + streamName);
            Record record = currentRecords.removeFirst();
            offsets.put(currentShardId, record.getSequenceNumber());
            return record;
        }
@ Override public Record next ( ) { if ( ! hasNext ( ) ) throw new NoSuchElementException ( "no more records for this iteration of " + streamName ) ; Record record = currentRecords . removeFirst ( ) ; offsets . put ( currentShardId , record . getSequenceNumber ( ) ) ; return record ; }
Returns the next record from the stream.
Returns the next record from the stream .