public class BigTableScanner extends java.lang.Object implements ISSTableScanner
Modifier and Type | Class and Description |
---|---|
static class |
BigTableScanner.EmptySSTableScanner |
protected class |
BigTableScanner.KeyScanningIterator |
Modifier and Type | Field and Description |
---|---|
protected RandomAccessReader |
dfile |
protected RandomAccessReader |
ifile |
protected java.util.Iterator<UnfilteredRowIterator> |
iterator |
SSTableReader |
sstable |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.lang.String |
getBackingFiles() |
long |
getBytesScanned() |
long |
getCompressedLengthInBytes() |
long |
getCurrentPosition() |
long |
getLengthInBytes() |
static ISSTableScanner |
getScanner(SSTableReader sstable,
java.util.Collection<Range<Token>> tokenRanges,
com.google.common.util.concurrent.RateLimiter limiter) |
static ISSTableScanner |
getScanner(SSTableReader sstable,
ColumnFilter columns,
DataRange dataRange,
com.google.common.util.concurrent.RateLimiter limiter,
SSTableReadsListener listener) |
static ISSTableScanner |
getScanner(SSTableReader sstable,
java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator) |
static ISSTableScanner |
getScanner(SSTableReader sstable,
com.google.common.util.concurrent.RateLimiter limiter) |
boolean |
hasNext() |
CFMetaData |
metadata() |
UnfilteredRowIterator |
next() |
void |
remove() |
java.lang.String |
toString() |
protected final RandomAccessReader dfile
protected final RandomAccessReader ifile
public final SSTableReader sstable
protected java.util.Iterator<UnfilteredRowIterator> iterator
public static ISSTableScanner getScanner(SSTableReader sstable, com.google.common.util.concurrent.RateLimiter limiter)
public static ISSTableScanner getScanner(SSTableReader sstable, ColumnFilter columns, DataRange dataRange, com.google.common.util.concurrent.RateLimiter limiter, SSTableReadsListener listener)
public static ISSTableScanner getScanner(SSTableReader sstable, java.util.Collection<Range<Token>> tokenRanges, com.google.common.util.concurrent.RateLimiter limiter)
public static ISSTableScanner getScanner(SSTableReader sstable, java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator)
public void close()
close
in interface java.lang.AutoCloseable
close
in interface BasePartitionIterator<UnfilteredRowIterator>
close
in interface CloseableIterator<UnfilteredRowIterator>
public long getLengthInBytes()
getLengthInBytes
in interface ISSTableScanner
public long getCurrentPosition()
getCurrentPosition
in interface ISSTableScanner
public long getBytesScanned()
getBytesScanned
in interface ISSTableScanner
public long getCompressedLengthInBytes()
getCompressedLengthInBytes
in interface ISSTableScanner
public java.lang.String getBackingFiles()
getBackingFiles
in interface ISSTableScanner
public CFMetaData metadata()
metadata
in interface UnfilteredPartitionIterator
public boolean hasNext()
hasNext
in interface java.util.Iterator<UnfilteredRowIterator>
public UnfilteredRowIterator next()
next
in interface java.util.Iterator<UnfilteredRowIterator>
public void remove()
remove
in interface java.util.Iterator<UnfilteredRowIterator>
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2018 The Apache Software Foundation