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
All Methods Static Methods Instance Methods Concrete Methods 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()
-
-
-
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 interfacejava.lang.AutoCloseable
- Specified by:
close
in interfaceBasePartitionIterator<UnfilteredRowIterator>
- Specified by:
close
in interfaceCloseableIterator<UnfilteredRowIterator>
-
getLengthInBytes
public long getLengthInBytes()
- Specified by:
getLengthInBytes
in interfaceISSTableScanner
-
getCurrentPosition
public long getCurrentPosition()
- Specified by:
getCurrentPosition
in interfaceISSTableScanner
-
getBytesScanned
public long getBytesScanned()
- Specified by:
getBytesScanned
in interfaceISSTableScanner
-
getCompressedLengthInBytes
public long getCompressedLengthInBytes()
- Specified by:
getCompressedLengthInBytes
in interfaceISSTableScanner
-
getBackingSSTables
public java.util.Set<SSTableReader> getBackingSSTables()
- Specified by:
getBackingSSTables
in interfaceISSTableScanner
-
metadata
public TableMetadata metadata()
- Specified by:
metadata
in interfaceUnfilteredPartitionIterator
-
hasNext
public boolean hasNext()
- Specified by:
hasNext
in interfacejava.util.Iterator<UnfilteredRowIterator>
-
next
public UnfilteredRowIterator next()
- Specified by:
next
in interfacejava.util.Iterator<UnfilteredRowIterator>
-
remove
public void remove()
- Specified by:
remove
in interfacejava.util.Iterator<UnfilteredRowIterator>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-