Uses of Class
org.apache.cassandra.db.ReadCommand
-
-
Uses of ReadCommand in org.apache.cassandra.db
Subclasses of ReadCommand in org.apache.cassandra.db Modifier and Type Class 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.Fields in org.apache.cassandra.db with type parameters of type ReadCommand Modifier and Type Field Description static IVersionedSerializer<ReadCommand>
ReadCommand. serializer
Methods in org.apache.cassandra.db that return ReadCommand Modifier and Type Method Description abstract ReadCommand
AbstractReadCommandBuilder. build()
ReadCommand
AbstractReadCommandBuilder.PartitionRangeBuilder. build()
ReadCommand
AbstractReadCommandBuilder.SinglePartitionBuilder. 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.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.Serializer. deserialize(DataInputPlus in, int version)
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 newReadCommand
instance with new limits.Methods in org.apache.cassandra.db that return types with arguments of type ReadCommand Modifier and Type Method Description Message<ReadCommand>
ReadCommand. createMessage(boolean trackRepairedData)
Creates a message for this command.Methods in org.apache.cassandra.db with parameters of type ReadCommand Modifier and Type Method 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.Method parameters in org.apache.cassandra.db with type arguments of type ReadCommand Modifier and Type Method Description void
ReadCommandVerbHandler. doVerb(Message<ReadCommand> message)
-
Uses of ReadCommand in org.apache.cassandra.index
Methods in org.apache.cassandra.index that return types with arguments of type ReadCommand Modifier and Type Method 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.Methods in org.apache.cassandra.index with parameters of type ReadCommand Modifier and Type Method 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. -
Uses of ReadCommand in org.apache.cassandra.index.internal
Fields in org.apache.cassandra.index.internal declared as ReadCommand Modifier and Type Field Description protected ReadCommand
CassandraIndexSearcher. command
Methods in org.apache.cassandra.index.internal that return types with arguments of type ReadCommand Modifier and Type Method Description java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator>
CassandraIndex. postProcessorFor(ReadCommand command)
No post processing of query results, just return them unchangedMethods in org.apache.cassandra.index.internal with parameters of type ReadCommand Modifier and Type Method Description java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator>
CassandraIndex. postProcessorFor(ReadCommand command)
No post processing of query results, just return them unchangedprotected abstract UnfilteredPartitionIterator
CassandraIndexSearcher. queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController)
Index.Searcher
CassandraIndex. searcherFor(ReadCommand command)
void
CassandraIndex. validate(ReadCommand command)
Constructors in org.apache.cassandra.index.internal with parameters of type ReadCommand Constructor Description CassandraIndexSearcher(ReadCommand command, RowFilter.Expression expression, CassandraIndex index)
-
Uses of ReadCommand in org.apache.cassandra.index.internal.composites
Methods in org.apache.cassandra.index.internal.composites with parameters of type ReadCommand Modifier and Type Method Description protected UnfilteredPartitionIterator
CompositesSearcher. queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController)
Constructors in org.apache.cassandra.index.internal.composites with parameters of type ReadCommand Constructor Description CompositesSearcher(ReadCommand command, RowFilter.Expression expression, CassandraIndex index)
-
Uses of ReadCommand in org.apache.cassandra.index.internal.keys
Methods in org.apache.cassandra.index.internal.keys with parameters of type ReadCommand Modifier and Type Method Description protected UnfilteredPartitionIterator
KeysSearcher. queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController)
Constructors in org.apache.cassandra.index.internal.keys with parameters of type ReadCommand Constructor Description KeysSearcher(ReadCommand command, RowFilter.Expression expression, CassandraIndex indexer)
-
Uses of ReadCommand in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi that return types with arguments of type ReadCommand Modifier and Type Method Description java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator>
SASIIndex. postProcessorFor(ReadCommand command)
Methods in org.apache.cassandra.index.sasi with parameters of type ReadCommand Modifier and Type Method Description java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator>
SASIIndex. postProcessorFor(ReadCommand command)
Index.Searcher
SASIIndex. searcherFor(ReadCommand command)
-
Uses of ReadCommand in org.apache.cassandra.index.sasi.plan
Constructors in org.apache.cassandra.index.sasi.plan with parameters of type ReadCommand Constructor Description QueryPlan(ColumnFamilyStore cfs, ReadCommand command, long executionQuotaMs)
-
Uses of ReadCommand in org.apache.cassandra.service
Constructors in org.apache.cassandra.service with parameters of type ReadCommand Constructor Description LocalReadRunnable(ReadCommand command, ReadCallback handler)
LocalReadRunnable(ReadCommand command, ReadCallback handler, boolean trackRepairedStatus)
-
Uses of ReadCommand in org.apache.cassandra.service.reads
Fields in org.apache.cassandra.service.reads declared as ReadCommand Modifier and Type Field Description protected ReadCommand
AbstractReadExecutor. command
protected ReadCommand
ResponseResolver. command
Methods in org.apache.cassandra.service.reads with parameters of type ReadCommand Modifier and Type Method 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)
Constructors in org.apache.cassandra.service.reads with parameters of type ReadCommand Constructor 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)
-
Uses of ReadCommand in org.apache.cassandra.service.reads.repair
Fields in org.apache.cassandra.service.reads.repair declared as ReadCommand Modifier and Type Field Description protected ReadCommand
AbstractReadRepair. command
protected ReadCommand
RepairedDataVerifier.SimpleVerifier. command
Methods in org.apache.cassandra.service.reads.repair with parameters of type ReadCommand Modifier and Type Method Description static <E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
ReadRepair<E,P>ReadRepair. create(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, long queryStartNanoTime)
<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
ReadRepair<E,P>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)
Constructors in org.apache.cassandra.service.reads.repair with parameters of type ReadCommand Constructor 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)
-