Package org.apache.cassandra.io.sstable

Class AbstractSSTableIterator.ForwardReader

java.lang.Object

AbstractSSTableIterator<RIE>.AbstractReader

org.apache.cassandra.io.sstable.AbstractSSTableIterator.ForwardReader

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<Unfiltered>, AbstractSSTableIterator.Reader

Enclosing class:

AbstractSSTableIterator<RIE extends AbstractRowIndexEntry>

protected class AbstractSSTableIterator.ForwardReader
extends AbstractSSTableIterator<RIE>.AbstractReader

Field Summary

Fields

Modifier and Type	Field	Description
protected ClusteringBound<?>	end
protected Unfiltered	next
protected boolean	sliceDone
protected ClusteringBound<?>	start

Fields inherited from class org.apache.cassandra.io.sstable.AbstractSSTableIterator.AbstractReader

deserializer, file, openMarker

Constructor Summary

Constructors

Constructor	Description
ForwardReader(FileDataInput file, boolean shouldCloseFile)

Method Summary

Modifier and Type	Method	Description
protected Unfiltered	computeNext()
protected boolean	hasNextInternal()
protected Unfiltered	nextInternal()
void	setForSlice(Slice slice)

Methods inherited from class org.apache.cassandra.io.sstable.AbstractSSTableIterator.AbstractReader

close, hasNext, next, seekToPosition, toString, updateOpenMarker

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, remove

Field Details

start

protected ClusteringBound<?> start

end

protected ClusteringBound<?> end

next

protected Unfiltered next

sliceDone

protected boolean sliceDone

Constructor Details

ForwardReader

public ForwardReader(FileDataInput file,
 boolean shouldCloseFile)

Method Details

setForSlice

public void setForSlice(Slice slice)
                 throws IOException

Specified by:

setForSlice in interface AbstractSSTableIterator.Reader

Specified by:

setForSlice in class AbstractSSTableIterator<RIE extends AbstractRowIndexEntry>.AbstractReader

Throws:

IOException

computeNext

protected Unfiltered computeNext()
                          throws IOException

Throws:

IOException

hasNextInternal

protected boolean hasNextInternal()
                           throws IOException

Specified by:

hasNextInternal in class AbstractSSTableIterator<RIE extends AbstractRowIndexEntry>.AbstractReader

Throws:

IOException

nextInternal

protected Unfiltered nextInternal()
                           throws IOException

Specified by:

nextInternal in class AbstractSSTableIterator<RIE extends AbstractRowIndexEntry>.AbstractReader

Throws:

IOException