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(java.util.List<SinglePartitionReadCommand> commands, DataLimits limits)
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 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.
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.
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

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

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, 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, 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 new QueryPager 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)