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