Package org.apache.cassandra.io.sstable.format

Class SSTableScanner<S extends SSTableReader,E extends AbstractRowIndexEntry,I extends SSTableScanner<S,E,I>.BaseKeyScanningIterator>

java.lang.Object

org.apache.cassandra.io.sstable.format.SSTableScanner<S,E,I>

All Implemented Interfaces:

AutoCloseable, Iterator<UnfilteredRowIterator>, BasePartitionIterator<UnfilteredRowIterator>, UnfilteredPartitionIterator, ISSTableScanner, CloseableIterator<UnfilteredRowIterator>

Direct Known Subclasses:

BigTableScanner, BtiTableScanner

public abstract class SSTableScanner<S extends SSTableReader,E extends AbstractRowIndexEntry,I extends SSTableScanner<S,E,I>.BaseKeyScanningIterator>
extends Object
implements ISSTableScanner

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	SSTableScanner.BaseKeyScanningIterator

Field Summary

Fields

Modifier and Type	Field	Description
protected long	bytesScanned
protected final ColumnFilter	columns
protected final DataRange	dataRange
protected final RandomAccessReader	dfile
protected final AtomicBoolean	isClosed
protected I	iterator
protected final Iterator<AbstractBounds<PartitionPosition>>	rangeIterator
protected final S	sstable
protected long	startScan

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SSTableScanner(S sstable, ColumnFilter columns, DataRange dataRange, Iterator<AbstractBounds<PartitionPosition>> rangeIterator, SSTableReadsListener listener)

Method Summary

Modifier and Type	Method	Description
void	close()
protected abstract void	doClose()
protected abstract I	doCreateIterator()
Set<SSTableReader>	getBackingSSTables()
long	getBytesScanned()
long	getCompressedLengthInBytes()
long	getCurrentPosition()
long	getLengthInBytes()
boolean	hasNext()
protected static List<AbstractBounds<PartitionPosition>>	makeBounds(SSTableReader sstable, DataRange dataRange)
TableMetadata	metadata()
UnfilteredRowIterator	next()
void	remove()
String	toString()

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

isClosed

protected final AtomicBoolean isClosed

dfile

protected final RandomAccessReader dfile

sstable

protected final S extends SSTableReader sstable

rangeIterator

protected final Iterator<AbstractBounds<PartitionPosition>> rangeIterator

columns

protected final ColumnFilter columns

dataRange

protected final DataRange dataRange

iterator

protected I extends SSTableScanner<S,E,I>.BaseKeyScanningIterator iterator

startScan

protected long startScan

bytesScanned

protected long bytesScanned

Constructor Details

SSTableScanner

protected SSTableScanner(S sstable,
 ColumnFilter columns,
 DataRange dataRange,
 Iterator<AbstractBounds<PartitionPosition>> rangeIterator,
 SSTableReadsListener listener)

Method Details

makeBounds

protected static List<AbstractBounds<PartitionPosition>> makeBounds(SSTableReader sstable,
 DataRange dataRange)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface BasePartitionIterator<S extends SSTableReader>

Specified by:

close in interface CloseableIterator<S extends SSTableReader>

doClose

protected abstract void doClose()
                         throws IOException

Throws:

IOException

getLengthInBytes

public long getLengthInBytes()

Specified by:

getLengthInBytes in interface ISSTableScanner

getCompressedLengthInBytes

public long getCompressedLengthInBytes()

Specified by:

getCompressedLengthInBytes in interface ISSTableScanner

getCurrentPosition

public long getCurrentPosition()

Specified by:

getCurrentPosition in interface ISSTableScanner

getBytesScanned

public long getBytesScanned()

Specified by:

getBytesScanned in interface ISSTableScanner

getBackingSSTables

public Set<SSTableReader> getBackingSSTables()

Specified by:

getBackingSSTables in interface ISSTableScanner

metadata

public TableMetadata metadata()

Specified by:

metadata in interface UnfilteredPartitionIterator

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<S extends SSTableReader>

next

public UnfilteredRowIterator next()

Specified by:

next in interface Iterator<S extends SSTableReader>

remove

public void remove()

Specified by:

remove in interface Iterator<S extends SSTableReader>

doCreateIterator

protected abstract I doCreateIterator()

toString

public String toString()

Overrides:

toString in class Object