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

Class BigTableScanner

java.lang.Object

org.apache.cassandra.io.sstable.format.big.BigTableScanner

All Implemented Interfaces:

java.lang.AutoCloseable, java.util.Iterator<UnfilteredRowIterator>, BasePartitionIterator<UnfilteredRowIterator>, UnfilteredPartitionIterator, ISSTableScanner, CloseableIterator<UnfilteredRowIterator>

public class BigTableScanner
extends java.lang.Object
implements ISSTableScanner

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BigTableScanner.EmptySSTableScanner
protected class	BigTableScanner.KeyScanningIterator

Field Summary

Fields

Modifier and Type	Field	Description
protected RandomAccessReader	dfile
protected RandomAccessReader	ifile
protected java.util.Iterator<UnfilteredRowIterator>	iterator
SSTableReader	sstable

Method Summary

Modifier and Type	Method	Description
void	close()
java.util.Set<SSTableReader>	getBackingSSTables()
long	getBytesScanned()
long	getCompressedLengthInBytes()
long	getCurrentPosition()
long	getLengthInBytes()
static ISSTableScanner	getScanner(SSTableReader sstable)
static ISSTableScanner	getScanner(SSTableReader sstable, java.util.Collection<Range<Token>> tokenRanges)
static ISSTableScanner	getScanner(SSTableReader sstable, java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator)
static ISSTableScanner	getScanner(SSTableReader sstable, ColumnFilter columns, DataRange dataRange, SSTableReadsListener listener)
boolean	hasNext()
TableMetadata	metadata()
UnfilteredRowIterator	next()
void	remove()
java.lang.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 Detail

dfile

protected final RandomAccessReader dfile

ifile

protected final RandomAccessReader ifile

sstable

public final SSTableReader sstable

iterator

protected java.util.Iterator<UnfilteredRowIterator> iterator

Method Detail

getScanner

public static ISSTableScanner getScanner(SSTableReader sstable)

getScanner

public static ISSTableScanner getScanner(SSTableReader sstable,
                                         ColumnFilter columns,
                                         DataRange dataRange,
                                         SSTableReadsListener listener)

getScanner

public static ISSTableScanner getScanner(SSTableReader sstable,
                                         java.util.Collection<Range<Token>> tokenRanges)

getScanner

public static ISSTableScanner getScanner(SSTableReader sstable,
                                         java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator)

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface BasePartitionIterator<UnfilteredRowIterator>

Specified by:

close in interface CloseableIterator<UnfilteredRowIterator>

getLengthInBytes

public long getLengthInBytes()

Specified by:

getLengthInBytes in interface ISSTableScanner

getCurrentPosition

public long getCurrentPosition()

Specified by:

getCurrentPosition in interface ISSTableScanner

getBytesScanned

public long getBytesScanned()

Specified by:

getBytesScanned in interface ISSTableScanner

getCompressedLengthInBytes

public long getCompressedLengthInBytes()

Specified by:

getCompressedLengthInBytes in interface ISSTableScanner

getBackingSSTables

public java.util.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 java.util.Iterator<UnfilteredRowIterator>

next

public UnfilteredRowIterator next()

Specified by:

next in interface java.util.Iterator<UnfilteredRowIterator>

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<UnfilteredRowIterator>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object