Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.db.filter | |
org.apache.cassandra.service.pager |
Modifier and Type | Method and Description |
---|---|
DataLimits |
ReadCommand.limits()
The limits set on this query.
|
DataLimits |
ReadQuery.limits()
The limits for the query.
|
DataLimits |
SinglePartitionReadCommand.Group.limits() |
protected DataLimits |
AbstractReadCommandBuilder.makeLimits() |
Modifier and Type | Method and Description |
---|---|
static PartitionRangeReadCommand |
PartitionRangeReadCommand.create(CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DataRange dataRange) |
static SinglePartitionReadCommand |
SinglePartitionReadCommand.create(CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter)
Creates a new read command on a single partition.
|
static SinglePartitionReadCommand |
SinglePartitionReadCommand.create(CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter,
IndexMetadata indexMetadata)
Creates a new read command on a single partition.
|
abstract ReadCommand |
ReadCommand.SelectionDeserializer.deserialize(DataInputPlus in,
int version,
boolean isDigest,
int digestVersion,
CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
IndexMetadata index) |
SinglePartitionReadCommand |
SinglePartitionReadCommand.forPaging(Clustering lastReturned,
DataLimits limits)
Returns a new command suitable to paging from the last returned row.
|
boolean |
ColumnFamilyStore.isFilterFullyCoveredBy(ClusteringIndexFilter filter,
DataLimits limits,
CachedPartition cached,
int nowInSec) |
ReadCommand |
PartitionRangeReadCommand.withUpdatedLimit(DataLimits newLimits) |
abstract ReadCommand |
ReadCommand.withUpdatedLimit(DataLimits newLimits)
Creates a new
ReadCommand instance with new limits. |
SinglePartitionReadCommand |
SinglePartitionReadCommand.withUpdatedLimit(DataLimits newLimits) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.withUpdatedLimitsAndDataRange(DataLimits newLimits,
DataRange newDataRange) |
Constructor and Description |
---|
Group(java.util.List<SinglePartitionReadCommand> commands,
DataLimits limits) |
ReadCommand(ReadCommand.Kind kind,
boolean isDigestQuery,
int digestVersion,
CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
IndexMetadata index) |
Modifier and Type | Field and Description |
---|---|
static DataLimits |
DataLimits.DISTINCT_NONE |
static DataLimits |
DataLimits.NONE |
Modifier and Type | Method and Description |
---|---|
static DataLimits |
DataLimits.cqlLimits(int cqlRowLimit) |
static DataLimits |
DataLimits.cqlLimits(int cqlRowLimit,
int perPartitionLimit) |
DataLimits |
DataLimits.Serializer.deserialize(DataInputPlus in,
int version,
ClusteringComparator comparator) |
static DataLimits |
DataLimits.distinctLimits(int cqlRowLimit) |
DataLimits |
DataLimits.forGroupByInternalPaging(GroupingState state)
Creates a
DataLimits instance to be used for paginating internally GROUP BY queries. |
abstract DataLimits |
DataLimits.forPaging(int pageSize) |
abstract DataLimits |
DataLimits.forPaging(int pageSize,
java.nio.ByteBuffer lastReturnedKey,
int lastReturnedKeyRemaining) |
abstract DataLimits |
DataLimits.forShortReadRetry(int toFetch) |
static DataLimits |
DataLimits.groupByLimits(int groupLimit,
int groupPerPartitionLimit,
int rowLimit,
AggregationSpecification groupBySpec) |
abstract DataLimits |
DataLimits.withoutState()
Returns equivalent limits but where any internal state kept to track where we are of paging and/or grouping is
discarded.
|
Modifier and Type | Method and Description |
---|---|
void |
DataLimits.Serializer.serialize(DataLimits limits,
DataOutputPlus out,
int version,
ClusteringComparator comparator) |
long |
DataLimits.Serializer.serializedSize(DataLimits limits,
int version,
ClusteringComparator comparator) |
Modifier and Type | Method and Description |
---|---|
DataLimits |
SinglePartitionPager.limits() |
Modifier and Type | Method and Description |
---|---|
protected QueryPager |
AggregationQueryPager.GroupByPartitionIterator.updatePagerLimit(QueryPager pager,
DataLimits limits,
java.nio.ByteBuffer lastPartitionKey,
Clustering lastClustering)
Updates the pager with the new limits if needed.
|
protected QueryPager |
AggregationQueryPager.AggregationPartitionIterator.updatePagerLimit(QueryPager pager,
DataLimits limits,
java.nio.ByteBuffer lastPartitionKey,
Clustering lastClustering) |
QueryPager |
AggregationQueryPager.withUpdatedLimit(DataLimits newLimits) |
QueryPager |
MultiPartitionPager.withUpdatedLimit(DataLimits newLimits) |
PartitionRangeQueryPager |
PartitionRangeQueryPager.withUpdatedLimit(DataLimits newLimits) |
QueryPager |
QueryPager.withUpdatedLimit(DataLimits newLimits)
Creates a new
QueryPager that use the new limits. |
SinglePartitionPager |
SinglePartitionPager.withUpdatedLimit(DataLimits newLimits) |
Constructor and Description |
---|
AggregationQueryPager(QueryPager subPager,
DataLimits limits) |
Copyright © 2018 The Apache Software Foundation