Modifier and Type | Method and Description |
---|---|
static UntypedResultSet |
QueryProcessor.resultify(java.lang.String query,
PartitionIterator partitions) |
Modifier and Type | Method and Description |
---|---|
ResultSet |
SelectStatement.process(PartitionIterator partitions,
int nowInSec) |
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
PartitionRangeReadCommand.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
ReadQuery.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime)
Executes the query at the provided consistency level.
|
PartitionIterator |
SinglePartitionReadCommand.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
SinglePartitionReadCommand.Group.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
ReadCommand.executeInternal(ReadExecutionController controller) |
PartitionIterator |
ReadQuery.executeInternal(ReadExecutionController controller)
Execute the query for internal queries (that is, it basically executes the query locally).
|
PartitionIterator |
SinglePartitionReadCommand.Group.executeInternal(ReadExecutionController controller) |
static PartitionIterator |
EmptyIterators.partition() |
PartitionIterator |
PartitionRangeReadCommand.postReconciliationProcessing(PartitionIterator result)
Allow to post-process the result of the query after it has been reconciled on the coordinator
but before it is passed to the CQL layer to return the ResultSet.
|
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
PartitionRangeReadCommand.postReconciliationProcessing(PartitionIterator result)
Allow to post-process the result of the query after it has been reconciled on the coordinator
but before it is passed to the CQL layer to return the ResultSet.
|
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
DataLimits.Counter.applyTo(PartitionIterator partitions) |
PartitionIterator |
DataLimits.filter(PartitionIterator iter,
int nowInSec,
boolean countPartitionsWithOnlyStaticData,
boolean enforceStrictLiveness) |
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
DataLimits.Counter.applyTo(PartitionIterator partitions) |
PartitionIterator |
DataLimits.filter(PartitionIterator iter,
int nowInSec,
boolean countPartitionsWithOnlyStaticData,
boolean enforceStrictLiveness) |
Modifier and Type | Method and Description |
---|---|
static PartitionIterator |
PartitionIterators.concat(java.util.List<PartitionIterator> iterators) |
static PartitionIterator |
UnfilteredPartitionIterators.filter(UnfilteredPartitionIterator iterator,
int nowInSec) |
static PartitionIterator |
PartitionIterators.loggingIterator(PartitionIterator iterator,
java.lang.String id)
Wraps the provided iterator so it logs the returned rows for debugging purposes.
|
static PartitionIterator |
PartitionIterators.singletonIterator(RowIterator iterator) |
Modifier and Type | Method and Description |
---|---|
static void |
PartitionIterators.consume(PartitionIterator iterator) |
static RowIterator |
PartitionIterators.getOnlyElement(PartitionIterator iter,
SinglePartitionReadCommand command) |
static PartitionIterator |
PartitionIterators.loggingIterator(PartitionIterator iterator,
java.lang.String id)
Wraps the provided iterator so it logs the returned rows for debugging purposes.
|
Modifier and Type | Method and Description |
---|---|
static PartitionIterator |
PartitionIterators.concat(java.util.List<PartitionIterator> iterators) |
Modifier and Type | Class and Description |
---|---|
class |
FilteredPartitions |
Modifier and Type | Method and Description |
---|---|
static PartitionIterator |
Transformation.apply(PartitionIterator iterator,
Transformation<? super RowIterator> transformation) |
static PartitionIterator |
MorePartitions.extend(PartitionIterator iterator,
MorePartitions<? super PartitionIterator> more) |
Modifier and Type | Method and Description |
---|---|
static PartitionIterator |
Transformation.apply(PartitionIterator iterator,
Transformation<? super RowIterator> transformation) |
static PartitionIterator |
MorePartitions.extend(PartitionIterator iterator,
MorePartitions<? super PartitionIterator> more) |
Modifier and Type | Method and Description |
---|---|
static PartitionIterator |
MorePartitions.extend(PartitionIterator iterator,
MorePartitions<? super PartitionIterator> more) |
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.
|
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> |
CassandraIndex.postProcessorFor(ReadCommand command)
No post processing of query results, just return them unchanged
|
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> |
SASIIndex.postProcessorFor(ReadCommand command) |
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator> |
SASIIndex.postProcessorFor(ReadCommand command) |
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
AbstractReadExecutor.get()
wait for an answer.
|
PartitionIterator |
ReadCallback.get() |
PartitionIterator |
DataResolver.getData() |
PartitionIterator |
DigestResolver.getData()
Special case of resolve() so that CL.ONE reads never throw DigestMismatchException in the foreground
|
abstract PartitionIterator |
ResponseResolver.getData() |
static PartitionIterator |
StorageProxy.getRangeSlice(PartitionRangeReadCommand command,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
static PartitionIterator |
StorageProxy.read(SinglePartitionReadCommand.Group group,
ConsistencyLevel consistencyLevel,
ClientState state,
long queryStartNanoTime)
Performs the actual reading of a row out of the StorageService, fetching
a specific set of column names from a given column family.
|
static PartitionIterator |
StorageProxy.read(SinglePartitionReadCommand.Group group,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
PartitionIterator |
DataResolver.resolve() |
PartitionIterator |
DigestResolver.resolve() |
abstract PartitionIterator |
ResponseResolver.resolve() |
Modifier and Type | Class and Description |
---|---|
class |
AggregationQueryPager.AggregationPartitionIterator
PartitionIterator for queries without Group By but with aggregates. |
class |
AggregationQueryPager.GroupByPartitionIterator
PartitionIterator that automatically fetch a new sub-page of data if needed when the current iterator is
exhausted. |
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
AggregationQueryPager.fetchPage(int pageSize,
ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
MultiPartitionPager.fetchPage(int pageSize,
ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
QueryPager.fetchPage(int pageSize,
ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime)
Fetches the next page.
|
PartitionIterator |
AggregationQueryPager.fetchPageInternal(int pageSize,
ReadExecutionController executionController) |
PartitionIterator |
MultiPartitionPager.fetchPageInternal(int pageSize,
ReadExecutionController executionController) |
PartitionIterator |
QueryPager.fetchPageInternal(int pageSize,
ReadExecutionController executionController)
Fetches the next page internally (in other, this does a local query).
|
Copyright © 2018 The Apache Software Foundation