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,
boolean isForThrift,
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() |
boolean |
isForThrift()
Whether that partition iterator is for a thrift queries.
|
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, boolean isForThrift, 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 boolean isForThrift()
UnfilteredPartitionIterator
If this is true, the partition iterator may return some empty UnfilteredRowIterator and those should be preserved as thrift include partitions that "exists" (have some cells even if this are actually deleted) but have nothing matching the query.
isForThrift
in interface UnfilteredPartitionIterator
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 © 2020 The Apache Software Foundation