public class FileTierPartitionIterator extends org.apache.kafka.common.utils.AbstractIterator<TierObjectMetadata>
Constructor and Description |
---|
FileTierPartitionIterator(TopicIdPartition topicIdPartition,
CheckedFileIO channel,
long startPosition) |
FileTierPartitionIterator(TopicIdPartition topicIdPartition,
CheckedFileIO channel,
long startPosition,
boolean useSharedEntryBuffer) |
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, CheckedFileIO channel, long startPosition) throws IOException
IOException
public FileTierPartitionIterator(TopicIdPartition topicIdPartition, CheckedFileIO channel, long startPosition, boolean useSharedEntryBuffer) throws IOException
IOException
protected TierObjectMetadata makeNext()
makeNext
in class org.apache.kafka.common.utils.AbstractIterator<TierObjectMetadata>
public long position()