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.legacyPagedRangeCommandSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.legacyRangeSliceCommandSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.legacyReadCommandSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.pagedRangeSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.rangeSliceSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.readSerializer |
static IVersionedSerializer<ReadCommand> |
ReadCommand.serializer |
Modifier and Type | Method and Description |
---|---|
abstract ReadCommand |
AbstractReadCommandBuilder.build() |
ReadCommand |
AbstractReadCommandBuilder.SinglePartitionBuilder.build() |
ReadCommand |
AbstractReadCommandBuilder.SinglePartitionSliceBuilder.build() |
ReadCommand |
AbstractReadCommandBuilder.PartitionRangeBuilder.build() |
abstract ReadCommand |
ReadCommand.copy()
Returns a copy of this command.
|
abstract ReadCommand |
ReadCommand.copyAsDigestQuery()
Returns a copy of this command with isDigestQuery set to true.
|
abstract ReadCommand |
ReadCommand.SelectionDeserializer.deserialize(DataInputPlus in,
int version,
boolean isDigest,
int digestVersion,
boolean isForThrift,
CFMetaData 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.
|
ReadCommand |
PartitionRangeReadCommand.withUpdatedLimit(DataLimits newLimits) |
abstract ReadCommand |
ReadCommand.withUpdatedLimit(DataLimits newLimits)
Creates a new
ReadCommand instance with new limits. |
Modifier and Type | Method and Description |
---|---|
MessageOut<ReadCommand> |
PartitionRangeReadCommand.createMessage(int version) |
abstract MessageOut<ReadCommand> |
ReadCommand.createMessage(int version)
Creates a message for this command.
|
MessageOut<ReadCommand> |
SinglePartitionReadCommand.createMessage(int version) |
Modifier and Type | Method and Description |
---|---|
static ReadResponse |
ReadResponse.createDataResponse(UnfilteredPartitionIterator data,
ReadCommand command) |
static ReadResponse |
ReadResponse.createDigestResponse(UnfilteredPartitionIterator data,
ReadCommand command) |
static ReadResponse |
ReadResponse.createRemoteDataResponse(UnfilteredPartitionIterator data,
ReadCommand command) |
abstract java.nio.ByteBuffer |
ReadResponse.digest(ReadCommand command) |
static LegacyLayout.LegacyUnfilteredPartition |
LegacyLayout.fromUnfilteredRowIterator(ReadCommand command,
UnfilteredRowIterator iterator) |
protected static java.nio.ByteBuffer |
ReadResponse.makeDigest(UnfilteredPartitionIterator iterator,
ReadCommand command) |
abstract UnfilteredPartitionIterator |
ReadResponse.makeIterator(ReadCommand command) |
static void |
LegacyLayout.serializeAsLegacyPartition(ReadCommand command,
UnfilteredRowIterator partition,
DataOutputPlus out,
int version) |
static long |
LegacyLayout.serializedSizeAsLegacyPartition(ReadCommand command,
UnfilteredRowIterator partition,
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(MessageIn<ReadCommand> message,
int id) |
Constructor and Description |
---|
ReadResponse(ReadCommand command) |
Modifier and Type | Method and Description |
---|---|
static void |
UnfilteredPartitionIterators.digest(ReadCommand command,
UnfilteredPartitionIterator iterator,
java.security.MessageDigest digest,
int version)
Digests the the provided iterator.
|
Modifier and Type | Method and Description |
---|---|
static void |
UnfilteredRowIterators.digest(ReadCommand command,
UnfilteredRowIterator iterator,
java.security.MessageDigest digest,
int version)
Digests the partition represented by the provided iterator.
|
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) |
Modifier and Type | Field and Description |
---|---|
protected ReadCommand |
AbstractReadExecutor.command |
protected ReadCommand |
ResponseResolver.command |
Constructor and Description |
---|
DigestResolver(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistency,
int maxResponseCount) |
NeverSpeculatingReadExecutor(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistencyLevel,
java.util.List<java.net.InetAddress> targetReplicas,
long queryStartNanoTime) |
ReadCallback(ResponseResolver resolver,
ConsistencyLevel consistencyLevel,
int blockfor,
ReadCommand command,
Keyspace keyspace,
java.util.List<java.net.InetAddress> endpoints,
long queryStartNanoTime) |
ReadCallback(ResponseResolver resolver,
ConsistencyLevel consistencyLevel,
ReadCommand command,
java.util.List<java.net.InetAddress> filteredEndpoints,
long queryStartNanoTime)
Constructor when response count has to be calculated and blocked for.
|
ResponseResolver(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistency,
int maxResponseCount) |
Modifier and Type | Method and Description |
---|---|
protected ReadCommand |
PartitionRangeQueryPager.nextPageReadCommand(int pageSize) |
protected ReadCommand |
SinglePartitionPager.nextPageReadCommand(int pageSize) |
Constructor and Description |
---|
PartitionRangeQueryPager(ReadCommand command,
ProtocolVersion protocolVersion,
DecoratedKey lastReturnedKey,
PagingState.RowMark lastReturnedRow,
int remaining,
int remainingInPartition) |
Copyright © 2020 The Apache Software Foundation