Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.index.sasi.plan | |
org.apache.cassandra.io.sstable.format | |
org.apache.cassandra.io.sstable.format.big |
Modifier and Type | Class and Description |
---|---|
static class |
DataRange.Paging
Specialized
DataRange used for the paging case. |
Modifier and Type | Method and Description |
---|---|
static DataRange |
DataRange.allData(IPartitioner partitioner)
Creates a
DataRange to query all data (over the whole ring). |
static DataRange |
DataRange.allData(IPartitioner partitioner,
ClusteringIndexFilter filter)
Creates a
DataRange to query all partitions of the ring using the provided
clustering index filter. |
DataRange |
PartitionRangeReadCommand.dataRange() |
DataRange |
DataRange.Serializer.deserialize(DataInputPlus in,
int version,
CFMetaData metadata) |
static DataRange |
DataRange.forKeyRange(Range<PartitionPosition> keyRange)
Creates a
DataRange to query all rows over the provided key range. |
DataRange |
DataRange.forPaging(AbstractBounds<PartitionPosition> range,
ClusteringComparator comparator,
Clustering lastReturned,
boolean inclusive)
Returns a new
DataRange for use when paging this range. |
DataRange |
DataRange.forSubRange(AbstractBounds<PartitionPosition> range)
Returns a new
DataRange equivalent to this one but restricted to the provided sub-range. |
DataRange |
DataRange.Paging.forSubRange(AbstractBounds<PartitionPosition> range) |
static DataRange |
DataRange.forTokenRange(Range<Token> tokenRange)
Creates a
DataRange to query all rows over the provided token range. |
Modifier and Type | Method and Description |
---|---|
static PartitionRangeReadCommand |
PartitionRangeReadCommand.create(boolean isForThrift,
CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DataRange dataRange) |
Memtable.MemtableUnfilteredPartitionIterator |
Memtable.makePartitionIterator(ColumnFilter columnFilter,
DataRange dataRange,
boolean isForThrift) |
void |
DataRange.Serializer.serialize(DataRange range,
DataOutputPlus out,
int version,
CFMetaData metadata) |
long |
DataRange.Serializer.serializedSize(DataRange range,
int version,
CFMetaData metadata) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.withUpdatedDataRange(DataRange newDataRange) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.withUpdatedLimitsAndDataRange(DataLimits newLimits,
DataRange newDataRange) |
Constructor and Description |
---|
MemtableUnfilteredPartitionIterator(ColumnFamilyStore cfs,
java.util.Iterator<java.util.Map.Entry<PartitionPosition,AtomicBTreePartition>> iter,
boolean isForThrift,
int minLocalDeletionTime,
ColumnFilter columnFilter,
DataRange dataRange) |
Modifier and Type | Method and Description |
---|---|
DataRange |
QueryController.dataRange() |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
ISSTableScanner |
BigTableReader.getScanner(ColumnFilter columns,
DataRange dataRange,
com.google.common.util.concurrent.RateLimiter limiter,
boolean isForThrift,
SSTableReadsListener listener) |
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
ColumnFilter columns,
DataRange dataRange,
com.google.common.util.concurrent.RateLimiter limiter,
boolean isForThrift,
SSTableReadsListener listener) |
Copyright © 2020 The Apache Software Foundation