Package org.apache.cassandra.io.sstable

Class AbstractSSTableIterator.AbstractReader

java.lang.Object

org.apache.cassandra.io.sstable.AbstractSSTableIterator.AbstractReader

All Implemented Interfaces:

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

Direct Known Subclasses:

AbstractSSTableIterator.ForwardReader

Enclosing class:

AbstractSSTableIterator<RIE extends AbstractRowIndexEntry>

public abstract class AbstractSSTableIterator.AbstractReader
extends Object
implements AbstractSSTableIterator.Reader

Field Summary

Fields

Modifier and Type	Field	Description
UnfilteredDeserializer	deserializer
FileDataInput	file
DeletionTime	openMarker

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractReader(FileDataInput file, boolean shouldCloseFile)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasNext()
protected abstract boolean	hasNextInternal()
Unfiltered	next()
protected abstract Unfiltered	nextInternal()
void	seekToPosition(long position)	Seek to the given position in the file.
abstract void	setForSlice(Slice slice)
String	toString()
protected void	updateOpenMarker(RangeTombstoneMarker marker)

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

file

public FileDataInput file

deserializer

public UnfilteredDeserializer deserializer

openMarker

public DeletionTime openMarker

Constructor Details

AbstractReader

protected AbstractReader(FileDataInput file,
 boolean shouldCloseFile)

Method Details

seekToPosition

public void seekToPosition(long position)
                    throws IOException

Seek to the given position in the file. Initializes the file reader along with a deserializer if they are not initialized yet. Otherwise, the deserializer is reset by calling its UnfilteredDeserializer.clearState() method.

Note that the only valid usage of this method is to seek to the beginning of the serialized record so that the deserializer can read the next unfiltered from that position. Setting an arbitrary position will lead to unexpected results and/or corrupted reads.

Specified by:

seekToPosition in interface AbstractSSTableIterator.Reader

Throws:

IOException

updateOpenMarker

protected void updateOpenMarker(RangeTombstoneMarker marker)

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Unfiltered>

next

public Unfiltered next()

Specified by:

next in interface Iterator<Unfiltered>

setForSlice

public abstract void setForSlice(Slice slice)
                          throws IOException

Specified by:

setForSlice in interface AbstractSSTableIterator.Reader

Throws:

IOException

hasNextInternal

protected abstract boolean hasNextInternal()
                                    throws IOException

Throws:

IOException

nextInternal

protected abstract Unfiltered nextInternal()
                                    throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object