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 SinglePartitionReadCommand |
SinglePartitionReadCommand.create(boolean isForThrift,
CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter)
Creates a new read command on a single partition for thrift.
|
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.
|
abstract ReadCommand |
ReadCommand.SelectionDeserializer.deserialize(DataInputPlus in,
int version,
boolean isDigest,
int digestVersion,
boolean isForThrift,
CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
java.util.Optional<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) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.withUpdatedLimit(DataLimits newLimits) |
Constructor and Description |
---|
Group(java.util.List<SinglePartitionReadCommand> commands,
DataLimits limits) |
PartitionRangeReadCommand(boolean isDigest,
int digestVersion,
boolean isForThrift,
CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DataRange dataRange,
java.util.Optional<IndexMetadata> index) |
PartitionRangeReadCommand(CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DataRange dataRange,
java.util.Optional<IndexMetadata> index) |
ReadCommand(ReadCommand.Kind kind,
boolean isDigestQuery,
int digestVersion,
boolean isForThrift,
CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits) |
SinglePartitionReadCommand(boolean isDigest,
int digestVersion,
boolean isForThrift,
CFMetaData metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter) |
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) |
static DataLimits |
DataLimits.distinctLimits(int cqlRowLimit) |
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.superColumnCountingLimits(int partitionLimit,
int cellPerPartitionLimit) |
static DataLimits |
DataLimits.thriftLimits(int partitionLimit,
int cellPerPartitionLimit) |
Modifier and Type | Method and Description |
---|---|
void |
DataLimits.Serializer.serialize(DataLimits limits,
DataOutputPlus out,
int version) |
long |
DataLimits.Serializer.serializedSize(DataLimits limits,
int version) |
Modifier and Type | Method and Description |
---|---|
DataLimits |
SinglePartitionPager.limits() |
Modifier and Type | Method and Description |
---|---|
static int |
QueryPagers.countPaged(CFMetaData metadata,
DecoratedKey key,
ColumnFilter columnFilter,
ClusteringIndexFilter filter,
DataLimits limits,
ConsistencyLevel consistencyLevel,
ClientState state,
int pageSize,
int nowInSec,
boolean isForThrift)
Convenience method that count (live) cells/rows for a given slice of a row, but page underneath.
|
Copyright © 2017 The Apache Software Foundation