| Package | Description |
|---|---|
| org.apache.cassandra.db | |
| org.apache.cassandra.index.sasi.plan | |
| org.apache.cassandra.service | |
| org.apache.cassandra.service.pager |
| Modifier and Type | Method and Description |
|---|---|
static PartitionRangeReadCommand |
PartitionRangeReadCommand.allDataRead(CFMetaData metadata,
int nowInSec)
Creates a new read command that query all the data in the table.
|
PartitionRangeReadCommand |
PartitionRangeReadCommand.copy() |
PartitionRangeReadCommand |
PartitionRangeReadCommand.copyAsDigestQuery() |
static PartitionRangeReadCommand |
PartitionRangeReadCommand.create(boolean isForThrift,
CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DataRange dataRange) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.forSubRange(AbstractBounds<PartitionPosition> range,
boolean isRangeContinuation)
Returns an equivalent command but that only queries data within the provided range.
|
PartitionRangeReadCommand |
PartitionRangeReadCommand.withUpdatedDataRange(DataRange newDataRange) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.withUpdatedLimitsAndDataRange(DataLimits newLimits,
DataRange newDataRange) |
| Constructor and Description |
|---|
QueryController(ColumnFamilyStore cfs,
PartitionRangeReadCommand command,
long timeQuotaMs) |
| Modifier and Type | Method and Description |
|---|---|
static PartitionIterator |
StorageProxy.getRangeSlice(PartitionRangeReadCommand command,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
| Constructor and Description |
|---|
RangeCommandIterator(java.util.Iterator<StorageProxy.RangeForQuery> ranges,
PartitionRangeReadCommand command,
int concurrencyFactor,
int maxConcurrencyFactor,
int totalRangeCount,
Keyspace keyspace,
ConsistencyLevel consistency,
long queryStartNanoTime) |
RangeIterator(PartitionRangeReadCommand command,
Keyspace keyspace,
ConsistencyLevel consistency) |
| Constructor and Description |
|---|
PartitionRangeQueryPager(PartitionRangeReadCommand command,
PagingState state,
ProtocolVersion protocolVersion) |
Copyright © 2009-2022 The Apache Software Foundation