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 classPartitionRangeReadCommandA read command that selects a (part of a) range of partitions.classSinglePartitionReadCommandA 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. serializerMethods in org.apache.cassandra.db that return ReadCommand Modifier and Type Method Description abstract ReadCommandAbstractReadCommandBuilder. build()ReadCommandAbstractReadCommandBuilder.PartitionRangeBuilder. build()ReadCommandAbstractReadCommandBuilder.SinglePartitionBuilder. build()abstract ReadCommandReadCommand. copy()Returns a copy of this command.protected abstract ReadCommandReadCommand. copyAsDigestQuery()ReadCommandReadCommand. copyAsDigestQuery(java.lang.Iterable<Replica> replicas)Returns a copy of this command with isDigestQuery set to true.ReadCommandReadCommand. copyAsDigestQuery(Replica replica)Returns a copy of this command with isDigestQuery set to true.protected abstract ReadCommandReadCommand. copyAsTransientQuery()ReadCommandReadCommand. copyAsTransientQuery(java.lang.Iterable<Replica> replicas)Returns a copy of this command with acceptsTransient set to true.ReadCommandReadCommand. copyAsTransientQuery(Replica replica)Returns a copy of this command with acceptsTransient set to true.abstract ReadCommandReadCommand.SelectionDeserializer. deserialize(DataInputPlus in, int version, boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, IndexMetadata index)ReadCommandReadCommand.Serializer. deserialize(DataInputPlus in, int version)ReadCommandReadCommand. setDigestVersion(int digestVersion)Sets the digest version, for when digest for that command is requested.abstract ReadCommandReadCommand. withUpdatedLimit(DataLimits newLimits)Creates a newReadCommandinstance 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 ReadResponseReadResponse. createDataResponse(UnfilteredPartitionIterator data, ReadCommand command, org.apache.cassandra.db.RepairedDataInfo rdi)static ReadResponseReadResponse. createDigestResponse(UnfilteredPartitionIterator data, ReadCommand command)static ReadResponseReadResponse. createRemoteDataResponse(UnfilteredPartitionIterator data, java.nio.ByteBuffer repairedDataDigest, boolean isRepairedDigestConclusive, ReadCommand command, int version)abstract java.nio.ByteBufferReadResponse. digest(ReadCommand command)protected static java.nio.ByteBufferReadResponse. makeDigest(UnfilteredPartitionIterator iterator, ReadCommand command)abstract UnfilteredPartitionIteratorReadResponse. makeIterator(ReadCommand command)voidReadCommand.Serializer. serialize(ReadCommand command, DataOutputPlus out, int version)longReadCommand.Serializer. serializedSize(ReadCommand command, int version)java.lang.StringReadResponse. 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 voidReadCommandVerbHandler. 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.SearcherIndex. searcherFor(ReadCommand command)Factory method for query time search helper.default voidIndex. 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 ReadCommandCassandraIndexSearcher. commandMethods 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 UnfilteredPartitionIteratorCassandraIndexSearcher. queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController)Index.SearcherCassandraIndex. searcherFor(ReadCommand command)voidCassandraIndex. 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 UnfilteredPartitionIteratorCompositesSearcher. 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 UnfilteredPartitionIteratorKeysSearcher. 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.SearcherSASIIndex. 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 ReadCommandAbstractReadExecutor. commandprotected ReadCommandResponseResolver. commandMethods in org.apache.cassandra.service.reads with parameters of type ReadCommand Modifier and Type Method Description static UnfilteredPartitionIteratorShortReadProtection. extend(Replica source, java.lang.Runnable preFetchCallback, UnfilteredPartitionIterator partitions, ReadCommand command, DataLimits.Counter mergedResultCounter, long queryStartNanoTime, boolean enforceStrictLiveness)protected RepairedDataVerifierDataResolver. 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 ReadCommandAbstractReadRepair. commandprotected ReadCommandRepairedDataVerifier.SimpleVerifier. commandMethods 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 RepairedDataVerifierRepairedDataVerifier. simple(ReadCommand command)static RepairedDataVerifierRepairedDataVerifier. snapshotting(ReadCommand command)static RepairedDataVerifierRepairedDataVerifier. 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)
-