Package | Description |
---|---|
org.apache.cassandra.db.compaction | |
org.apache.cassandra.io.sstable.format | |
org.apache.cassandra.io.sstable.format.big | |
org.apache.cassandra.tools |
Modifier and Type | Field and Description |
---|---|
java.util.List<ISSTableScanner> |
AbstractCompactionStrategy.ScannerList.scanners |
Constructor and Description |
---|
CompactionIterator(OperationType type,
java.util.List<ISSTableScanner> scanners,
CompactionController controller,
int nowInSec,
java.util.UUID compactionId) |
CompactionIterator(OperationType type,
java.util.List<ISSTableScanner> scanners,
CompactionController controller,
int nowInSec,
java.util.UUID compactionId,
CompactionMetrics metrics) |
ScannerList(java.util.List<ISSTableScanner> scanners) |
Modifier and Type | Method and Description |
---|---|
ISSTableScanner |
SSTableReader.getScanner()
I/O SSTableScanner
|
abstract ISSTableScanner |
SSTableReader.getScanner(java.util.Collection<Range<Token>> ranges,
com.google.common.util.concurrent.RateLimiter limiter)
Direct I/O SSTableScanner over a defined collection of ranges of tokens.
|
ISSTableScanner |
SSTableReader.getScanner(ColumnFilter columns,
DataRange dataRange,
boolean isForThrift,
SSTableReadsListener listener) |
abstract ISSTableScanner |
SSTableReader.getScanner(ColumnFilter columns,
DataRange dataRange,
com.google.common.util.concurrent.RateLimiter limiter,
boolean isForThrift,
SSTableReadsListener listener) |
abstract ISSTableScanner |
SSTableReader.getScanner(java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator)
Direct I/O SSTableScanner over an iterator of bounds.
|
ISSTableScanner |
SSTableReader.getScanner(Range<Token> range,
com.google.common.util.concurrent.RateLimiter limiter)
Direct I/O SSTableScanner over a defined range of tokens.
|
abstract ISSTableScanner |
SSTableReader.getScanner(com.google.common.util.concurrent.RateLimiter limiter)
Direct I/O SSTableScanner over the entirety of the sstable..
|
Modifier and Type | Class and Description |
---|---|
class |
BigTableScanner |
static class |
BigTableScanner.EmptySSTableScanner |
Modifier and Type | Method and Description |
---|---|
ISSTableScanner |
BigTableReader.getScanner(java.util.Collection<Range<Token>> ranges,
com.google.common.util.concurrent.RateLimiter limiter)
Direct I/O SSTableScanner over a defined collection of ranges of tokens.
|
ISSTableScanner |
BigTableReader.getScanner(ColumnFilter columns,
DataRange dataRange,
com.google.common.util.concurrent.RateLimiter limiter,
boolean isForThrift,
SSTableReadsListener listener) |
ISSTableScanner |
BigTableReader.getScanner(java.util.Iterator<AbstractBounds<PartitionPosition>> boundsIterator)
Direct I/O SSTableScanner over an iterator of bounds.
|
ISSTableScanner |
BigTableReader.getScanner(com.google.common.util.concurrent.RateLimiter limiter)
Direct I/O SSTableScanner over the full sstable.
|
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
java.util.Collection<Range<Token>> tokenRanges,
com.google.common.util.concurrent.RateLimiter limiter) |
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
ColumnFilter columns,
DataRange dataRange,
com.google.common.util.concurrent.RateLimiter limiter,
boolean isForThrift,
SSTableReadsListener listener) |
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator) |
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
com.google.common.util.concurrent.RateLimiter limiter) |
Modifier and Type | Method and Description |
---|---|
static void |
JsonTransformer.keysToJson(ISSTableScanner currentScanner,
java.util.stream.Stream<DecoratedKey> keys,
boolean rawTime,
CFMetaData metadata,
java.io.OutputStream out) |
static void |
JsonTransformer.toJson(ISSTableScanner currentScanner,
java.util.stream.Stream<UnfilteredRowIterator> partitions,
boolean rawTime,
CFMetaData metadata,
java.io.OutputStream out) |
Copyright © 2020 The Apache Software Foundation