Uses of Class
org.apache.cassandra.db.filter.DataLimits

Packages that use DataLimits

Package	Description
org.apache.cassandra.cql3.statements
org.apache.cassandra.db
org.apache.cassandra.db.filter
org.apache.cassandra.service.pager

Uses of DataLimits in org.apache.cassandra.cql3.statements

Methods in org.apache.cassandra.cql3.statements with parameters of type DataLimits

Modifier and Type	Method	Description
ReadQuery	SelectStatement.getQuery(QueryOptions options, ClientState state, ColumnFilter columnFilter, long nowInSec, DataLimits limit)

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, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange)
static ReadQuery	PartitionRangeReadQuery.create(TableMetadata table, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange)
static SinglePartitionReadCommand	SinglePartitionReadCommand.create(TableMetadata metadata, long 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, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, Index.QueryPlan indexQueryPlan)	Creates a new read command on a single partition.
static SinglePartitionReadCommand.Group	SinglePartitionReadCommand.Group.create(List<SinglePartitionReadCommand> commands, DataLimits limits)
static SinglePartitionReadCommand.Group	SinglePartitionReadCommand.Group.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter)
static SinglePartitionReadQuery	SinglePartitionReadQuery.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter)	Creates a new read query on a single partition.
static SinglePartitionReadQuery.Group<? extends SinglePartitionReadQuery>	SinglePartitionReadQuery.createGroup(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter)
abstract ReadCommand	ReadCommand.SelectionDeserializer.deserialize(DataInputPlus in, int version, boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, Index.QueryPlan indexQueryPlan)
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.
boolean	ColumnFamilyStore.isFilterFullyCoveredBy(ClusteringIndexFilter filter, DataLimits limits, CachedPartition cached, long 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.
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.

Constructors in org.apache.cassandra.db with parameters of type DataLimits

Modifier	Constructor	Description
	Group(List<T> queries, DataLimits limits)
protected	PartitionRangeReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange, Index.QueryPlan indexQueryPlan, boolean trackWarnings)
protected	ReadCommand(ReadCommand.Kind kind, boolean isDigestQuery, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, Index.QueryPlan indexQueryPlan, boolean trackWarnings, DataRange dataRange)
protected	SinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, Index.QueryPlan indexQueryPlan, boolean trackWarnings, DataRange dataRange)
	VirtualTableGroup(List<SinglePartitionReadCommand> commands, DataLimits limits)
protected	VirtualTableSinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, Index.QueryPlan indexQueryPlan, boolean trackWarnings, DataRange dataRange)

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 final DataLimits	DataLimits.DISTINCT_NONE
static final 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, TableMetadata metadata)
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, 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 final DataLimits	AbstractQueryPager.limits
protected final 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, ByteBuffer lastPartitionKey, Clustering<?> lastClustering)
protected QueryPager	AggregationQueryPager.GroupByPartitionIterator.updatePagerLimit(QueryPager pager, DataLimits limits, 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 new QueryPager that use the new limits.
SinglePartitionPager	SinglePartitionPager.withUpdatedLimit(DataLimits newLimits)

Constructors in org.apache.cassandra.service.pager with parameters of type DataLimits

Modifier	Constructor	Description
	AggregationQueryPager(QueryPager subPager, DataLimits limits)