public class FileTierPartitionIterator extends org.apache.kafka.common.utils.AbstractIterator<TierObjectMetadata>
Constructor and Description |
---|
FileTierPartitionIterator(TopicIdPartition topicIdPartition,
java.nio.channels.FileChannel channel,
long startPosition) |
Modifier and Type | Method and Description |
---|---|
protected TierObjectMetadata |
makeNext() |
long |
position() |
allDone, hasNext, next, peek, remove
public FileTierPartitionIterator(TopicIdPartition topicIdPartition, java.nio.channels.FileChannel channel, long startPosition) throws java.io.IOException
java.io.IOException
protected TierObjectMetadata makeNext()
makeNext
in class org.apache.kafka.common.utils.AbstractIterator<TierObjectMetadata>
public long position()