Class KeyRangeIterator
- java.lang.Object
-
- org.apache.cassandra.index.sasi.utils.AbstractIterator<T>
-
- org.apache.cassandra.index.sasi.utils.RangeIterator<java.lang.Long,Token>
-
- org.apache.cassandra.index.sasi.memory.KeyRangeIterator
-
- All Implemented Interfaces:
com.google.common.collect.PeekingIterator<Token>,java.io.Closeable,java.lang.AutoCloseable,java.util.Iterator<Token>
public class KeyRangeIterator extends RangeIterator<java.lang.Long,Token>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.cassandra.index.sasi.utils.RangeIterator
RangeIterator.Builder<K extends java.lang.Comparable<K>,D extends CombinedValue<K>>
-
Nested classes/interfaces inherited from class org.apache.cassandra.index.sasi.utils.AbstractIterator
AbstractIterator.State
-
-
Field Summary
-
Fields inherited from class org.apache.cassandra.index.sasi.utils.AbstractIterator
next, state
-
-
Constructor Summary
Constructors Constructor Description KeyRangeIterator(java.util.concurrent.ConcurrentSkipListSet<DecoratedKey> keys, int size)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()protected TokencomputeNext()Returns the next element.protected voidperformSkipTo(java.lang.Long nextToken)-
Methods inherited from class org.apache.cassandra.index.sasi.utils.RangeIterator
getCount, getCurrent, getMaximum, getMinimum, isOverlapping, isOverlapping, recomputeNext, skipTo, tryToComputeNext
-
Methods inherited from class org.apache.cassandra.index.sasi.utils.AbstractIterator
endOfData, hasNext, next, peek, remove
-
-
-
-
Constructor Detail
-
KeyRangeIterator
public KeyRangeIterator(java.util.concurrent.ConcurrentSkipListSet<DecoratedKey> keys, int size)
-
-
Method Detail
-
computeNext
protected Token computeNext()
Description copied from class:AbstractIteratorReturns the next element. Note: the implementation must callAbstractIterator.endOfData()when there are no elements left in the iteration. Failure to do so could result in an infinite loop.The initial invocation of
AbstractIterator.hasNext()orAbstractIterator.next()calls this method, as does the first invocation ofhasNextornextfollowing each successful call tonext. Once the implementation either invokesendOfDataor throws an exception,computeNextis guaranteed to never be called again.If this method throws an exception, it will propagate outward to the
hasNextornextinvocation that invoked this method. Any further attempts to use the iterator will result in anIllegalStateException.The implementation of this method may not invoke the
hasNext,next, orAbstractIterator.peek()methods on this instance; if it does, anIllegalStateExceptionwill result.- Specified by:
computeNextin classAbstractIterator<Token>- Returns:
- the next element if there was one. If
endOfDatawas called during execution, the return value will be ignored.
-
performSkipTo
protected void performSkipTo(java.lang.Long nextToken)
- Specified by:
performSkipToin classRangeIterator<java.lang.Long,Token>
-
close
public void close() throws java.io.IOException- Throws:
java.io.IOException
-
-