Package org.iq80.leveldb.util

Class MergingIterator

java.lang.Object

org.iq80.leveldb.util.AbstractSeekingIterator<InternalKey,Slice>

org.iq80.leveldb.util.MergingIterator

All Implemented Interfaces:

com.google.common.collect.PeekingIterator<Map.Entry<InternalKey,Slice>>, Iterator<Map.Entry<InternalKey,Slice>>, SeekingIterator<InternalKey,Slice>

public final class MergingIterator
extends AbstractSeekingIterator<InternalKey,Slice>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	MergingIterator.ComparableIterator

Field Summary

Fields

Modifier and Type	Field	Description
private final Comparator<InternalKey>	comparator
private final List<? extends InternalIterator>	levels
private final PriorityQueue<MergingIterator.ComparableIterator>	priorityQueue

Constructor Summary

Constructors

Constructor	Description
MergingIterator(List<? extends InternalIterator> levels, Comparator<InternalKey> comparator)

Method Summary

Modifier and Type	Method	Description
protected Map.Entry<InternalKey,Slice>	getNextElement()
private void	resetPriorityQueue(Comparator<InternalKey> comparator)
protected void	seekInternal(InternalKey targetKey)
protected void	seekToFirstInternal()
String	toString()

Methods inherited from class org.iq80.leveldb.util.AbstractSeekingIterator

hasNext, next, peek, remove, seek, seekToFirst

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Details

levels

private final List<? extends InternalIterator> levels

priorityQueue

private final PriorityQueue<MergingIterator.ComparableIterator> priorityQueue

comparator

private final Comparator<InternalKey> comparator

Constructor Details

MergingIterator

public MergingIterator(List<? extends InternalIterator> levels,
 Comparator<InternalKey> comparator)

Method Details

seekToFirstInternal

protected void seekToFirstInternal()

Specified by:

seekToFirstInternal in class AbstractSeekingIterator<InternalKey,Slice>

seekInternal

protected void seekInternal(InternalKey targetKey)

Specified by:

seekInternal in class AbstractSeekingIterator<InternalKey,Slice>

resetPriorityQueue

private void resetPriorityQueue(Comparator<InternalKey> comparator)

getNextElement

protected Map.Entry<InternalKey,Slice> getNextElement()

Specified by:

getNextElement in class AbstractSeekingIterator<InternalKey,Slice>

toString

public String toString()

Overrides:

toString in class Object