Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.db.filter | |
org.apache.cassandra.service.pager |
Modifier and Type | Method and Description |
---|---|
DataLimits |
ReadQuery.limits()
The limits for the query.
|
DataLimits |
SinglePartitionReadQuery.Group.limits() |
protected DataLimits |
AbstractReadCommandBuilder.makeLimits() |
Modifier and Type | Method and Description |
---|---|
static PartitionRangeReadCommand |
PartitionRangeReadCommand.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DataRange dataRange) |
static ReadQuery |
PartitionRangeReadQuery.create(TableMetadata table,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DataRange dataRange) |
static VirtualTablePartitionRangeReadQuery |
VirtualTablePartitionRangeReadQuery.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DataRange dataRange) |
static SinglePartitionReadCommand |
SinglePartitionReadCommand.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter)
Creates a new read command on a single partition.
|
static SinglePartitionReadQuery |
SinglePartitionReadQuery.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter)
Creates a new read query on a single partition.
|
static VirtualTableSinglePartitionReadQuery |
VirtualTableSinglePartitionReadQuery.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter) |
static SinglePartitionReadCommand |
SinglePartitionReadCommand.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter,
IndexMetadata indexMetadata)
Creates a new read command on a single partition.
|
static SinglePartitionReadCommand.Group |
SinglePartitionReadCommand.Group.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
java.util.List<DecoratedKey> partitionKeys,
ClusteringIndexFilter clusteringIndexFilter) |
static VirtualTableSinglePartitionReadQuery.Group |
VirtualTableSinglePartitionReadQuery.Group.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
java.util.List<DecoratedKey> partitionKeys,
ClusteringIndexFilter clusteringIndexFilter) |
static SinglePartitionReadQuery.Group<? extends SinglePartitionReadQuery> |
SinglePartitionReadQuery.createGroup(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
java.util.List<DecoratedKey> partitionKeys,
ClusteringIndexFilter clusteringIndexFilter) |
abstract ReadCommand |
ReadCommand.SelectionDeserializer.deserialize(DataInputPlus in,
int version,
boolean isDigest,
int digestVersion,
boolean acceptsTransient,
TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
IndexMetadata index) |
SinglePartitionReadCommand |
SinglePartitionReadCommand.forPaging(Clustering<?> lastReturned,
DataLimits limits) |
SinglePartitionReadQuery |
SinglePartitionReadQuery.forPaging(Clustering<?> lastReturned,
DataLimits limits)
Returns a new
SinglePartitionReadQuery suitable to paging from the last returned row. |
SinglePartitionReadQuery |
VirtualTableSinglePartitionReadQuery.forPaging(Clustering<?> lastReturned,
DataLimits limits) |
boolean |
ColumnFamilyStore.isFilterFullyCoveredBy(ClusteringIndexFilter filter,
DataLimits limits,
CachedPartition cached,
int nowInSec,
boolean enforceStrictLiveness) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.withUpdatedLimit(DataLimits newLimits) |
PartitionRangeReadQuery |
PartitionRangeReadQuery.withUpdatedLimit(DataLimits newLimits)
Creates a new
PartitionRangeReadQuery with the updated limits. |
abstract ReadCommand |
ReadCommand.withUpdatedLimit(DataLimits newLimits)
Creates a new
ReadCommand instance with new limits. |
SinglePartitionReadCommand |
SinglePartitionReadCommand.withUpdatedLimit(DataLimits newLimits) |
SinglePartitionReadQuery |
SinglePartitionReadQuery.withUpdatedLimit(DataLimits newLimits)
Creates a new
SinglePartitionReadQuery with the specified limits. |
PartitionRangeReadQuery |
VirtualTablePartitionRangeReadQuery.withUpdatedLimit(DataLimits newLimits) |
SinglePartitionReadQuery |
VirtualTableSinglePartitionReadQuery.withUpdatedLimit(DataLimits newLimits) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.withUpdatedLimitsAndDataRange(DataLimits newLimits,
DataRange newDataRange) |
PartitionRangeReadQuery |
PartitionRangeReadQuery.withUpdatedLimitsAndDataRange(DataLimits newLimits,
DataRange newDataRange)
Creates a new
PartitionRangeReadQuery with the updated limits and data range. |
PartitionRangeReadQuery |
VirtualTablePartitionRangeReadQuery.withUpdatedLimitsAndDataRange(DataLimits newLimits,
DataRange newDataRange) |
Constructor and Description |
---|
Group(java.util.List<SinglePartitionReadCommand> commands,
DataLimits limits) |
Group(java.util.List<T> queries,
DataLimits limits) |
Group(java.util.List<VirtualTableSinglePartitionReadQuery> queries,
DataLimits limits) |
ReadCommand(ReadCommand.Kind kind,
boolean isDigestQuery,
int digestVersion,
boolean acceptsTransient,
TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
IndexMetadata index) |
SinglePartitionReadCommand(boolean isDigest,
int digestVersion,
boolean acceptsTransient,
TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter,
IndexMetadata index) |
VirtualTableReadQuery(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits) |
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 © 2009-2022 The Apache Software Foundation