Uses of Class
org.apache.cassandra.db.filter.DataLimits
-
Packages that use DataLimits Package Description org.apache.cassandra.db org.apache.cassandra.db.filter org.apache.cassandra.service.pager -
-
Uses of DataLimits in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return DataLimits Modifier and Type Method Description DataLimits
ReadQuery. limits()
The limits for the query.DataLimits
SinglePartitionReadQuery.Group. limits()
protected DataLimits
AbstractReadCommandBuilder. makeLimits()
Methods in org.apache.cassandra.db with parameters of type DataLimits Modifier and Type Method 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 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 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 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 VirtualTablePartitionRangeReadQuery
VirtualTablePartitionRangeReadQuery. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange)
static VirtualTableSinglePartitionReadQuery
VirtualTableSinglePartitionReadQuery. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, 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 newSinglePartitionReadQuery
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 newPartitionRangeReadQuery
with the updated limits.abstract ReadCommand
ReadCommand. withUpdatedLimit(DataLimits newLimits)
Creates a newReadCommand
instance with new limits.SinglePartitionReadCommand
SinglePartitionReadCommand. withUpdatedLimit(DataLimits newLimits)
SinglePartitionReadQuery
SinglePartitionReadQuery. withUpdatedLimit(DataLimits newLimits)
Creates a newSinglePartitionReadQuery
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 newPartitionRangeReadQuery
with the updated limits and data range.PartitionRangeReadQuery
VirtualTablePartitionRangeReadQuery. withUpdatedLimitsAndDataRange(DataLimits newLimits, DataRange newDataRange)
Constructors in org.apache.cassandra.db with parameters of type DataLimits Constructor 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)
-
Uses of DataLimits in org.apache.cassandra.db.filter
Fields in org.apache.cassandra.db.filter declared as DataLimits Modifier and Type Field Description static DataLimits
DataLimits. DISTINCT_NONE
static DataLimits
DataLimits. NONE
Methods in org.apache.cassandra.db.filter that return DataLimits Modifier and Type Method 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 aDataLimits
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.Methods in org.apache.cassandra.db.filter with parameters of type DataLimits Modifier and Type Method Description void
DataLimits.Serializer. serialize(DataLimits limits, DataOutputPlus out, int version, ClusteringComparator comparator)
long
DataLimits.Serializer. serializedSize(DataLimits limits, int version, ClusteringComparator comparator)
-
Uses of DataLimits in org.apache.cassandra.service.pager
Fields in org.apache.cassandra.service.pager declared as DataLimits Modifier and Type Field Description protected DataLimits
AbstractQueryPager. limits
protected DataLimits
AbstractQueryPager. limits
Methods in org.apache.cassandra.service.pager that return DataLimits Modifier and Type Method Description DataLimits
SinglePartitionPager. limits()
Methods in org.apache.cassandra.service.pager with parameters of type DataLimits Modifier and Type Method Description protected QueryPager
AggregationQueryPager.AggregationPartitionIterator. updatePagerLimit(QueryPager pager, DataLimits limits, java.nio.ByteBuffer lastPartitionKey, Clustering<?> lastClustering)
protected QueryPager
AggregationQueryPager.GroupByPartitionIterator. updatePagerLimit(QueryPager pager, DataLimits limits, java.nio.ByteBuffer lastPartitionKey, Clustering<?> lastClustering)
Updates the pager with the new limits if needed.QueryPager
AggregationQueryPager. withUpdatedLimit(DataLimits newLimits)
QueryPager
MultiPartitionPager. withUpdatedLimit(DataLimits newLimits)
PartitionRangeQueryPager
PartitionRangeQueryPager. withUpdatedLimit(DataLimits newLimits)
QueryPager
QueryPager. withUpdatedLimit(DataLimits newLimits)
Creates a newQueryPager
that use the new limits.SinglePartitionPager
SinglePartitionPager. withUpdatedLimit(DataLimits newLimits)
Constructors in org.apache.cassandra.service.pager with parameters of type DataLimits Constructor Description AggregationQueryPager(QueryPager subPager, DataLimits limits)
-