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 |
VirtualTableReadQuery.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
VirtualTableSinglePartitionReadQuery.Group.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
ReadQuery.executeInternal(ReadExecutionController controller)
Execute the query for internal queries (that is, it basically executes the query locally).
|
PartitionIterator |
SinglePartitionReadQuery.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) |
PartitionIterator |
RowFilter.filter(PartitionIterator iter,
TableMetadata metadata,
int nowInSec)
Filters the provided iterator so that only the row satisfying the expression of this filter
are included in the resulting iterator.
|
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
DataLimits.Counter.applyTo(PartitionIterator partitions) |
PartitionIterator |
DataLimits.filter(PartitionIterator iter,
int nowInSec,
boolean countPartitionsWithOnlyStaticData,
boolean enforceStrictLiveness) |
PartitionIterator |
RowFilter.filter(PartitionIterator iter,
TableMetadata metadata,
int nowInSec)
Filters the provided iterator so that only the row satisfying the expression of this filter
are included in the resulting iterator.
|
Modifier and Type | Method and Description |
---|---|
static PartitionIterator |
PartitionIterators.concat(java.util.List<PartitionIterator> iterators) |
static PartitionIterator |
PartitionIterators.doOnClose(PartitionIterator delegate,
java.lang.Runnable action)
Wraps the provided iterator to run a specified action on close.
|
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 void |
PartitionIterators.consumeNext(PartitionIterator iterator)
Consumes all rows in the next partition of the provided partition iterator.
|
static PartitionIterator |
PartitionIterators.doOnClose(PartitionIterator delegate,
java.lang.Runnable action)
Wraps the provided iterator to run a specified action on close.
|
static RowIterator |
PartitionIterators.getOnlyElement(PartitionIterator iter,
SinglePartitionReadQuery query) |
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 |
DuplicateRowChecker.duringRead(PartitionIterator iterator,
java.util.List<InetAddressAndPort> replicas) |
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 |
DuplicateRowChecker.duringRead(PartitionIterator iterator,
java.util.List<InetAddressAndPort> replicas) |
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 | Class and Description |
---|---|
static class |
StorageProxy.RangeCommandIterator |
Modifier and Type | Method and Description |
---|---|
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) |
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).
|
Modifier and Type | Field and Description |
---|---|
protected PartitionIterator |
AbstractReadExecutor.result |
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
DataResolver.getData() |
PartitionIterator |
DigestResolver.getData() |
PartitionIterator |
AbstractReadExecutor.getResult() |
PartitionIterator |
DataResolver.resolve() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractReadExecutor.setResult(PartitionIterator result) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractReadRepair.startRepair(DigestResolver<E,P> digestResolver,
java.util.function.Consumer<PartitionIterator> resultConsumer) |
void |
NoopReadRepair.startRepair(DigestResolver<E,P> digestResolver,
java.util.function.Consumer<PartitionIterator> resultConsumer) |
void |
ReadRepair.startRepair(DigestResolver<E,P> digestResolver,
java.util.function.Consumer<PartitionIterator> resultConsumer)
Called when the digests from the initial read don't match.
|
Copyright © 2009-2020 The Apache Software Foundation