Modifier and Type | Class and Description |
---|---|
class |
PartitionRangeReadCommand
A read command that selects a (part of a) range of partitions.
|
class |
SinglePartitionReadCommand
A read command that selects a (part of a) single partition.
|
Modifier and Type | Field and Description |
---|---|
static IVersionedSerializer<ReadCommand> |
ReadCommand.legacyPagedRangeCommandSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.legacyRangeSliceCommandSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.legacyReadCommandSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.pagedRangeSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.rangeSliceSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.readSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.serializer |
Modifier and Type | Method and Description |
---|---|
abstract ReadCommand |
AbstractReadCommandBuilder.build() |
ReadCommand |
AbstractReadCommandBuilder.SinglePartitionBuilder.build() |
ReadCommand |
AbstractReadCommandBuilder.SinglePartitionSliceBuilder.build() |
ReadCommand |
AbstractReadCommandBuilder.PartitionRangeBuilder.build() |
abstract ReadCommand |
ReadCommand.copy()
Returns a copy of this command.
|
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) |
ReadCommand |
ReadCommand.setDigestVersion(int digestVersion)
Sets the digest version, for when digest for that command is requested.
|
ReadCommand |
ReadCommand.setIsDigestQuery(boolean isDigestQuery)
Sets whether this command should be a digest one or not.
|
Modifier and Type | Method and Description |
---|---|
MessageOut<ReadCommand> |
PartitionRangeReadCommand.createMessage(int version) |
abstract MessageOut<ReadCommand> |
ReadCommand.createMessage(int version)
Creates a message for this command.
|
MessageOut<ReadCommand> |
SinglePartitionReadCommand.createMessage(int version) |
Modifier and Type | Method and Description |
---|---|
void |
ReadCommandVerbHandler.doVerb(MessageIn<ReadCommand> message,
int id) |
Constructor and Description |
---|
ReadResponse(ReadCommand command) |
Modifier and Type | Method and Description |
---|---|
static void |
UnfilteredPartitionIterators.digest(ReadCommand command,
UnfilteredPartitionIterator iterator,
java.security.MessageDigest digest,
int version)
Digests the the provided iterator.
|
Modifier and Type | Method and Description |
---|---|
static void |
UnfilteredRowIterators.digest(ReadCommand command,
UnfilteredRowIterator iterator,
java.security.MessageDigest digest,
int version)
Digests the partition represented by the provided iterator.
|
Modifier and Type | Method and Description |
---|---|
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator> |
Index.postProcessorFor(ReadCommand command)
Return a function which performs post processing on the results of a partition range read command.
|
Modifier and Type | Method and Description |
---|---|
Index |
SecondaryIndexManager.getBestIndexFor(ReadCommand command)
Called at query time to choose which (if any) of the registered index implementations to use for a given query.
|
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator> |
Index.postProcessorFor(ReadCommand command)
Return a function which performs post processing on the results of a partition range read command.
|
Index.Searcher |
Index.searcherFor(ReadCommand command)
Factory method for query time search helper.
|
default void |
Index.validate(ReadCommand command)
Used to validate the various parameters of a supplied ReadCommand,
this is called prior to execution.
|
Modifier and Type | Field and Description |
---|---|
protected ReadCommand |
CassandraIndexSearcher.command |
Modifier and Type | Method and Description |
---|---|
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator> |
CassandraIndex.postProcessorFor(ReadCommand command)
No post processing of query results, just return them unchanged
|
Modifier and Type | Method and Description |
---|---|
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator> |
CassandraIndex.postProcessorFor(ReadCommand command)
No post processing of query results, just return them unchanged
|
protected abstract UnfilteredPartitionIterator |
CassandraIndexSearcher.queryDataFromIndex(DecoratedKey indexKey,
RowIterator indexHits,
ReadCommand command,
ReadExecutionController executionController) |
Index.Searcher |
CassandraIndex.searcherFor(ReadCommand command) |
void |
CassandraIndex.validate(ReadCommand command) |
Constructor and Description |
---|
CassandraIndexSearcher(ReadCommand command,
RowFilter.Expression expression,
CassandraIndex index) |
Modifier and Type | Method and Description |
---|---|
protected UnfilteredPartitionIterator |
CompositesSearcher.queryDataFromIndex(DecoratedKey indexKey,
RowIterator indexHits,
ReadCommand command,
ReadExecutionController executionController) |
Constructor and Description |
---|
CompositesSearcher(ReadCommand command,
RowFilter.Expression expression,
CassandraIndex index) |
Modifier and Type | Method and Description |
---|---|
protected UnfilteredPartitionIterator |
KeysSearcher.queryDataFromIndex(DecoratedKey indexKey,
RowIterator indexHits,
ReadCommand command,
ReadExecutionController executionController) |
Constructor and Description |
---|
KeysSearcher(ReadCommand command,
RowFilter.Expression expression,
CassandraIndex indexer) |
Modifier and Type | Method and Description |
---|---|
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator> |
SASIIndex.postProcessorFor(ReadCommand command) |
Modifier and Type | Method and Description |
---|---|
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator> |
SASIIndex.postProcessorFor(ReadCommand command) |
Index.Searcher |
SASIIndex.searcherFor(ReadCommand command) |
Constructor and Description |
---|
QueryPlan(ColumnFamilyStore cfs,
ReadCommand command,
long executionQuotaMs) |
Modifier and Type | Field and Description |
---|---|
protected ReadCommand |
AbstractReadExecutor.command |
protected ReadCommand |
ResponseResolver.command |
Constructor and Description |
---|
DataResolver(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistency,
int maxResponseCount) |
DigestResolver(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistency,
int maxResponseCount) |
NeverSpeculatingReadExecutor(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistencyLevel,
java.util.List<java.net.InetAddress> targetReplicas) |
ReadCallback(ResponseResolver resolver,
ConsistencyLevel consistencyLevel,
int blockfor,
ReadCommand command,
Keyspace keyspace,
java.util.List<java.net.InetAddress> endpoints) |
ReadCallback(ResponseResolver resolver,
ConsistencyLevel consistencyLevel,
ReadCommand command,
java.util.List<java.net.InetAddress> filteredEndpoints)
Constructor when response count has to be calculated and blocked for.
|
ResponseResolver(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistency,
int maxResponseCount) |
Modifier and Type | Method and Description |
---|---|
protected ReadCommand |
PartitionRangeQueryPager.nextPageReadCommand(int pageSize) |
protected ReadCommand |
SinglePartitionPager.nextPageReadCommand(int pageSize) |
Copyright © 2017 The Apache Software Foundation