Uses of Class
org.apache.cassandra.db.ReadCommand

Packages that use ReadCommand

Package	Description
org.apache.cassandra.db
org.apache.cassandra.index
org.apache.cassandra.index.internal
org.apache.cassandra.index.internal.composites
org.apache.cassandra.index.internal.keys
org.apache.cassandra.index.sasi
org.apache.cassandra.index.sasi.plan
org.apache.cassandra.service
org.apache.cassandra.service.paxos.uncommitted
org.apache.cassandra.service.reads
org.apache.cassandra.service.reads.repair
org.apache.cassandra.service.reads.thresholds

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.
static class	PartitionRangeReadCommand.VirtualTablePartitionRangeReadCommand
class	SinglePartitionReadCommand	A read command that selects a (part of a) single partition.
static class	SinglePartitionReadCommand.VirtualTableSinglePartitionReadCommand

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)
static ReadCommand	ReadCommand.getCommand()
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.

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, Dispatcher.RequestTime requestTime)	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 unchanged

Methods 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 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)

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

Method parameters in org.apache.cassandra.service with type arguments of type ReadCommand

Modifier and Type	Method	Description
static void	StorageProxy.logRequestException(java.lang.Exception exception, java.util.Collection<? extends ReadCommand> commands)

Constructors in org.apache.cassandra.service with parameters of type ReadCommand

Constructor	Description
LocalReadRunnable(ReadCommand command, ReadCallback handler, Dispatcher.RequestTime requestTime)
LocalReadRunnable(ReadCommand command, ReadCallback handler, Dispatcher.RequestTime requestTime, boolean trackRepairedStatus)

Uses of ReadCommand in org.apache.cassandra.service.paxos.uncommitted

Methods in org.apache.cassandra.service.paxos.uncommitted that return types with arguments of type ReadCommand

Modifier and Type	Method	Description
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator>	PaxosUncommittedIndex.postProcessorFor(ReadCommand command)

Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type ReadCommand

Modifier and Type	Method	Description
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator>	PaxosUncommittedIndex.postProcessorFor(ReadCommand command)
Index.Searcher	PaxosUncommittedIndex.searcherFor(ReadCommand command)

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, Dispatcher.RequestTime requestTime, 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, java.util.function.Supplier<? extends P> replicaPlan, ReadRepair<E,P> readRepair, Dispatcher.RequestTime requestTime)
DataResolver(ReadCommand command, java.util.function.Supplier<? extends P> replicaPlan, ReadRepair<E,P> readRepair, Dispatcher.RequestTime requestTime, boolean trackRepairedStatus)
DigestResolver(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)
NeverSpeculatingReadExecutor(ColumnFamilyStore cfs, ReadCommand command, ReplicaPlan.ForTokenRead replicaPlan, Dispatcher.RequestTime requestTime, boolean logFailedSpeculation)
ReadCallback(ResponseResolver<E,P> resolver, ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)
ResponseResolver(ReadCommand command, java.util.function.Supplier<? extends P> replicaPlan, Dispatcher.RequestTime requestTime)
ShortReadPartitionsProtection(ReadCommand command, Replica source, java.lang.Runnable preFetchCallback, DataLimits.Counter singleResultCounter, DataLimits.Counter mergedResultCounter, Dispatcher.RequestTime requestTime)

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,P>> ReadRepair<E,P>	ReadRepair.create(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)
<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>> ReadRepair<E,P>	ReadRepair.Factory.create(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)
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, Dispatcher.RequestTime requestTime)
PartitionIteratorMergeListener(ReplicaPlan.ForRead<E,?> replicaPlan, ReadCommand command, ReadRepair readRepair)
RowIteratorMergeListener(DecoratedKey partitionKey, RegularAndStaticColumns columns, boolean isReversed, ReplicaPlan.ForRead<E,?> readPlan, ReadCommand command, ReadRepair readRepair)

Uses of ReadCommand in org.apache.cassandra.service.reads.thresholds

Methods in org.apache.cassandra.service.reads.thresholds with parameters of type ReadCommand

Modifier and Type	Method	Description
void	WarningsSnapshot.maybeAbort(ReadCommand command, ConsistencyLevel cl, int received, int blockFor, boolean isDataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
static void	CoordinatorWarnings.update(ReadCommand cmd, WarningsSnapshot snapshot)