Uses of Class
org.apache.cassandra.db.ReadCommand
Packages that use ReadCommand
Package
Description
-
Uses of ReadCommand in org.apache.cassandra.db
Subclasses of ReadCommand in org.apache.cassandra.dbModifier and TypeClassDescriptionclassA read command that selects a (part of a) range of partitions.static classclassA read command that selects a (part of a) single partition.static classFields in org.apache.cassandra.db with type parameters of type ReadCommandModifier and TypeFieldDescriptionstatic final IVersionedSerializer<ReadCommand>ReadCommand.serializerMethods in org.apache.cassandra.db that return ReadCommandModifier and TypeMethodDescriptionabstract ReadCommandAbstractReadCommandBuilder.build()AbstractReadCommandBuilder.PartitionRangeBuilder.build()AbstractReadCommandBuilder.SinglePartitionBuilder.build()abstract ReadCommandReadCommand.copy()Returns a copy of this command.protected abstract ReadCommandReadCommand.copyAsDigestQuery()ReadCommand.copyAsDigestQuery(Iterable<Replica> replicas) Returns a copy of this command with isDigestQuery set to true.ReadCommand.copyAsDigestQuery(Replica replica) Returns a copy of this command with isDigestQuery set to true.protected abstract ReadCommandReadCommand.copyAsTransientQuery()ReadCommand.copyAsTransientQuery(Iterable<Replica> replicas) Returns a copy of this command with acceptsTransient set to true.ReadCommand.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, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, Index.QueryPlan indexQueryPlan) ReadCommand.Serializer.deserialize(DataInputPlus in, int version) static ReadCommandReadCommand.getCommand()ReadCommand.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 ReadCommandModifier and TypeMethodDescriptionReadCommand.createMessage(boolean trackRepairedData, Dispatcher.RequestTime requestTime) Creates a message for this command.Methods in org.apache.cassandra.db with parameters of type ReadCommandModifier and TypeMethodDescriptionstatic ReadResponseReadResponse.createDataResponse(UnfilteredPartitionIterator data, ReadCommand command, org.apache.cassandra.db.RepairedDataInfo rdi) static ReadResponseReadResponse.createDigestResponse(UnfilteredPartitionIterator data, ReadCommand command) static ReadResponseReadResponse.createRemoteDataResponse(UnfilteredPartitionIterator data, ByteBuffer repairedDataDigest, boolean isRepairedDigestConclusive, ReadCommand command, int version) abstract ByteBufferReadResponse.digest(ReadCommand command) protected static 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) 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 ReadCommandModifier and TypeMethodDescriptionvoidReadCommandVerbHandler.doVerb(Message<ReadCommand> message) -
Uses of ReadCommand in org.apache.cassandra.exceptions
Constructors in org.apache.cassandra.exceptions with parameters of type ReadCommand -
Uses of ReadCommand in org.apache.cassandra.index
Methods in org.apache.cassandra.index that return ReadCommandModifier and TypeMethodDescriptionIndex.Searcher.command()Returns theReadCommandfor which this searcher has been created.Methods in org.apache.cassandra.index with parameters of type ReadCommandModifier and TypeMethodDescriptiondefault Function<PartitionIterator,PartitionIterator> Index.QueryPlan.postProcessor(ReadCommand command) Return a function which performs post processing on the results of a partition range read command.Index.QueryPlan.searcherFor(ReadCommand command) Factory method for query time search helper.Index.searcherFor(ReadCommand command) Factory method for query time search helper.SingletonIndexQueryPlan.searcherFor(ReadCommand command) default voidIndex.QueryPlan.validate(ReadCommand command) Used to validate the various parameters of a suppliedReadCommandagainst the indexes in this plan.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 ReadCommandMethods in org.apache.cassandra.index.internal that return ReadCommandMethods in org.apache.cassandra.index.internal with parameters of type ReadCommandModifier and TypeMethodDescriptionprotected abstract UnfilteredPartitionIteratorCassandraIndexSearcher.queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) CassandraIndex.searcherFor(ReadCommand command) voidCassandraIndex.validate(ReadCommand command) Constructors in org.apache.cassandra.index.internal with parameters of type ReadCommandModifierConstructorDescriptionCassandraIndexSearcher(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 ReadCommandModifier and TypeMethodDescriptionprotected UnfilteredPartitionIteratorCompositesSearcher.queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) Constructors in org.apache.cassandra.index.internal.composites with parameters of type ReadCommandModifierConstructorDescriptionCompositesSearcher(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 ReadCommandModifier and TypeMethodDescriptionprotected UnfilteredPartitionIteratorKeysSearcher.queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) Constructors in org.apache.cassandra.index.internal.keys with parameters of type ReadCommandModifierConstructorDescriptionKeysSearcher(ReadCommand command, RowFilter.Expression expression, CassandraIndex indexer) -
Uses of ReadCommand in org.apache.cassandra.index.sai
Methods in org.apache.cassandra.index.sai with parameters of type ReadCommandModifier and TypeMethodDescriptionStorageAttachedIndex.searcherFor(ReadCommand command) voidStorageAttachedIndex.validate(ReadCommand command) Constructors in org.apache.cassandra.index.sai with parameters of type ReadCommand -
Uses of ReadCommand in org.apache.cassandra.index.sai.plan
Methods in org.apache.cassandra.index.sai.plan that return ReadCommandMethods in org.apache.cassandra.index.sai.plan with parameters of type ReadCommandModifier and TypeMethodDescriptionStorageAttachedIndexQueryPlan.postProcessor(ReadCommand command) Called on coordinator after merging replica responses before returning to clientStorageAttachedIndexQueryPlan.searcherFor(ReadCommand command) Constructors in org.apache.cassandra.index.sai.plan with parameters of type ReadCommandModifierConstructorDescriptionQueryController(ColumnFamilyStore cfs, ReadCommand command, RowFilter indexFilter, QueryContext queryContext) StorageAttachedIndexSearcher(ColumnFamilyStore cfs, TableQueryMetrics tableQueryMetrics, ReadCommand command, RowFilter indexFilter, long executionQuotaMs) VectorTopKProcessor(ReadCommand command) -
Uses of ReadCommand in org.apache.cassandra.index.sai.utils
Constructors in org.apache.cassandra.index.sai.utils with parameters of type ReadCommandModifierConstructorDescriptionInMemoryPartitionIterator(ReadCommand command, TreeMap<PartitionInfo, TreeSet<Unfiltered>> rowsByPartitions) InMemoryUnfilteredPartitionIterator(ReadCommand command, TreeMap<PartitionInfo, TreeSet<Unfiltered>> rowsByPartitions) -
Uses of ReadCommand in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type ReadCommand -
Uses of ReadCommand in org.apache.cassandra.index.sasi.plan
Methods in org.apache.cassandra.index.sasi.plan that return ReadCommandConstructors in org.apache.cassandra.index.sasi.plan with parameters of type ReadCommandModifierConstructorDescriptionQueryController(ColumnFamilyStore cfs, ReadCommand command, long timeQuotaMs) SASIIndexSearcher(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 ReadCommandModifier and TypeMethodDescriptionstatic voidStorageProxy.logRequestException(Exception exception, Collection<? extends ReadCommand> commands) Constructors in org.apache.cassandra.service with parameters of type ReadCommandModifierConstructorDescriptionLocalReadRunnable(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 with parameters of type ReadCommand -
Uses of ReadCommand in org.apache.cassandra.service.reads
Fields in org.apache.cassandra.service.reads declared as ReadCommandModifier and TypeFieldDescriptionprotected final ReadCommandAbstractReadExecutor.commandprotected final ReadCommandResponseResolver.commandMethods in org.apache.cassandra.service.reads with parameters of type ReadCommandModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorShortReadProtection.extend(Replica source, Runnable preFetchCallback, UnfilteredPartitionIterator partitions, ReadCommand command, DataLimits.Counter mergedResultCounter, Dispatcher.RequestTime requestTime, boolean enforceStrictLiveness) protected RepairedDataVerifierDataResolver.getRepairedDataVerifier(ReadCommand command) Constructors in org.apache.cassandra.service.reads with parameters of type ReadCommandModifierConstructorDescriptionDataResolver(ReadCommand command, Supplier<? extends P> replicaPlan, ReadRepair<E, P> readRepair, Dispatcher.RequestTime requestTime) DataResolver(ReadCommand command, 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, Supplier<? extends P> replicaPlan, Dispatcher.RequestTime requestTime) ShortReadPartitionsProtection(ReadCommand command, Replica source, 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 ReadCommandModifier and TypeFieldDescriptionprotected final ReadCommandAbstractReadRepair.commandprotected final ReadCommandRepairedDataVerifier.SimpleVerifier.commandMethods in org.apache.cassandra.service.reads.repair with parameters of type ReadCommandModifier and TypeMethodDescriptionstatic <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 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 ReadCommandModifierConstructorDescriptionAbstractReadRepair(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<E, ?> readRepair) -
Uses of ReadCommand in org.apache.cassandra.service.reads.thresholds
Methods in org.apache.cassandra.service.reads.thresholds with parameters of type ReadCommandModifier and TypeMethodDescriptionvoidWarningsSnapshot.maybeAbort(ReadCommand command, ConsistencyLevel cl, int received, int blockFor, boolean isDataPresent, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) static voidCoordinatorWarnings.update(ReadCommand cmd, WarningsSnapshot snapshot)