public class SegmentStateIterator extends org.apache.kafka.common.utils.AbstractIterator<SegmentState>
Constructor and Description |
---|
SegmentStateIterator(TopicIdPartition topicIdPartition,
CheckedFileIO channel,
long startPosition) |
Modifier and Type | Method and Description |
---|---|
protected SegmentState |
makeNext() |
long |
position() |
allDone, hasNext, next, peek, remove
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
public SegmentStateIterator(TopicIdPartition topicIdPartition, CheckedFileIO channel, long startPosition) throws IOException
IOException
protected SegmentState makeNext()
makeNext
in class org.apache.kafka.common.utils.AbstractIterator<SegmentState>
public long position()