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 |
---|---|
long |
position() |
hasNext, next, peek, remove
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
public SegmentStateIterator(TopicIdPartition topicIdPartition, CheckedFileIO channel, long startPosition) throws IOException
IOException