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.serializer |
Modifier and Type | Method and Description |
---|---|
abstract ReadCommand |
AbstractReadCommandBuilder.build() |
ReadCommand |
AbstractReadCommandBuilder.SinglePartitionBuilder.build() |
ReadCommand |
AbstractReadCommandBuilder.PartitionRangeBuilder.build() |
abstract ReadCommand |
ReadCommand.copy()
Returns a copy of this command.
|
protected abstract ReadCommand |
ReadCommand.copyAsDigestQuery() |
ReadCommand |
ReadCommand.copyAsDigestQuery(java.lang.Iterable<Replica> replicas)
Returns a copy of this command with isDigestQuery set to true.
|
ReadCommand |
ReadCommand.copyAsDigestQuery(Replica replica)
Returns a copy of this command with isDigestQuery set to true.
|
protected abstract ReadCommand |
ReadCommand.copyAsTransientQuery() |
ReadCommand |
ReadCommand.copyAsTransientQuery(java.lang.Iterable<Replica> replicas)
Returns a copy of this command with acceptsTransient set to true.
|
ReadCommand |
ReadCommand.copyAsTransientQuery(Replica replica)
Returns a copy of this command with acceptsTransient set to true.
|
ReadCommand |
ReadCommand.Serializer.deserialize(DataInputPlus in,
int version) |
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) |
ReadCommand |
ReadCommand.setDigestVersion(int digestVersion)
Sets the digest version, for when digest for that command is requested.
|
abstract ReadCommand |
ReadCommand.withUpdatedLimit(DataLimits newLimits)
Creates a new
ReadCommand instance with new limits. |
Modifier and Type | Method and Description |
---|---|
Message<ReadCommand> |
ReadCommand.createMessage(boolean trackRepairedData)
Creates a message for this command.
|
Modifier and Type | Method and Description |
---|---|
static ReadResponse |
ReadResponse.createDataResponse(UnfilteredPartitionIterator data,
ReadCommand command,
org.apache.cassandra.db.RepairedDataInfo rdi) |
static ReadResponse |
ReadResponse.createDigestResponse(UnfilteredPartitionIterator data,
ReadCommand command) |
static ReadResponse |
ReadResponse.createRemoteDataResponse(UnfilteredPartitionIterator data,
java.nio.ByteBuffer repairedDataDigest,
boolean isRepairedDigestConclusive,
ReadCommand command,
int version) |
abstract java.nio.ByteBuffer |
ReadResponse.digest(ReadCommand command) |
protected static java.nio.ByteBuffer |
ReadResponse.makeDigest(UnfilteredPartitionIterator iterator,
ReadCommand command) |
abstract UnfilteredPartitionIterator |
ReadResponse.makeIterator(ReadCommand command) |
void |
ReadCommand.Serializer.serialize(ReadCommand command,
DataOutputPlus out,
int version) |
long |
ReadCommand.Serializer.serializedSize(ReadCommand command,
int version) |
java.lang.String |
ReadResponse.toDebugString(ReadCommand command,
DecoratedKey key)
Creates a string of the requested partition in this read response suitable for debugging.
|
Modifier and Type | Method and Description |
---|---|
void |
ReadCommandVerbHandler.doVerb(Message<ReadCommand> message) |
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 |
---|---|
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) |
Constructor and Description |
---|
LocalReadRunnable(ReadCommand command,
ReadCallback handler) |
LocalReadRunnable(ReadCommand command,
ReadCallback handler,
boolean trackRepairedStatus) |
Modifier and Type | Field and Description |
---|---|
protected ReadCommand |
AbstractReadExecutor.command |
protected ReadCommand |
ResponseResolver.command |
Modifier and Type | Method and Description |
---|---|
static UnfilteredPartitionIterator |
ShortReadProtection.extend(Replica source,
java.lang.Runnable preFetchCallback,
UnfilteredPartitionIterator partitions,
ReadCommand command,
DataLimits.Counter mergedResultCounter,
long queryStartNanoTime,
boolean enforceStrictLiveness) |
protected RepairedDataVerifier |
DataResolver.getRepairedDataVerifier(ReadCommand command) |
Constructor and Description |
---|
DataResolver(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
ReadRepair<E,P> readRepair,
long queryStartNanoTime) |
DataResolver(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
ReadRepair<E,P> readRepair,
long queryStartNanoTime,
boolean trackRepairedStatus) |
DigestResolver(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
long queryStartNanoTime) |
NeverSpeculatingReadExecutor(ColumnFamilyStore cfs,
ReadCommand command,
ReplicaPlan.ForTokenRead replicaPlan,
long queryStartNanoTime,
boolean logFailedSpeculation) |
ReadCallback(ResponseResolver<E,P> resolver,
ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
long queryStartNanoTime) |
ResponseResolver(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
long queryStartNanoTime) |
ShortReadPartitionsProtection(ReadCommand command,
Replica source,
java.lang.Runnable preFetchCallback,
DataLimits.Counter singleResultCounter,
DataLimits.Counter mergedResultCounter,
long queryStartNanoTime) |
Modifier and Type | Field and Description |
---|---|
protected ReadCommand |
AbstractReadRepair.command |
protected ReadCommand |
RepairedDataVerifier.SimpleVerifier.command |
Modifier and Type | Method and Description |
---|---|
static <E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
ReadRepair.create(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
long queryStartNanoTime) |
<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
ReadRepair.Factory.create(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
long queryStartNanoTime) |
static RepairedDataVerifier |
RepairedDataVerifier.simple(ReadCommand command) |
static RepairedDataVerifier |
RepairedDataVerifier.snapshotting(ReadCommand command) |
static RepairedDataVerifier |
RepairedDataVerifier.verifier(ReadCommand command) |
Constructor and Description |
---|
AbstractReadRepair(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
long queryStartNanoTime) |
PartitionIteratorMergeListener(ReplicaPlan.ForRead<E> replicaPlan,
ReadCommand command,
ReadRepair readRepair) |
RowIteratorMergeListener(DecoratedKey partitionKey,
RegularAndStaticColumns columns,
boolean isReversed,
ReplicaPlan.ForRead<E> readPlan,
ReadCommand command,
ReadRepair readRepair) |
Copyright © 2009-2022 The Apache Software Foundation