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 |
---|---|
long |
position() |
hasNext, next, peek, remove
equals, 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