Uses of Interface
org.apache.cassandra.db.partitions.PartitionIterator
-
-
Uses of PartitionIterator in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 with parameters of type PartitionIterator Modifier and Type Method Description static UntypedResultSet
QueryProcessor. resultify(java.lang.String query, PartitionIterator partitions)
-
Uses of PartitionIterator in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements with parameters of type PartitionIterator Modifier and Type Method Description ResultSet
SelectStatement. process(PartitionIterator partitions, int nowInSec)
-
Uses of PartitionIterator in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return PartitionIterator Modifier and Type Method 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.Methods in org.apache.cassandra.db with parameters of type PartitionIterator Modifier and Type Method 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. -
Uses of PartitionIterator in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter that return PartitionIterator Modifier and Type Method 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.Methods in org.apache.cassandra.db.filter with parameters of type PartitionIterator Modifier and Type Method 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. -
Uses of PartitionIterator in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions that return PartitionIterator Modifier and Type Method 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)
Methods in org.apache.cassandra.db.partitions with parameters of type PartitionIterator Modifier and Type Method 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.Method parameters in org.apache.cassandra.db.partitions with type arguments of type PartitionIterator Modifier and Type Method Description static PartitionIterator
PartitionIterators. concat(java.util.List<PartitionIterator> iterators)
-
Uses of PartitionIterator in org.apache.cassandra.db.transform
Classes in org.apache.cassandra.db.transform that implement PartitionIterator Modifier and Type Class Description class
FilteredPartitions
Methods in org.apache.cassandra.db.transform that return PartitionIterator Modifier and Type Method 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)
Methods in org.apache.cassandra.db.transform with parameters of type PartitionIterator Modifier and Type Method 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)
Method parameters in org.apache.cassandra.db.transform with type arguments of type PartitionIterator Modifier and Type Method Description static PartitionIterator
MorePartitions. extend(PartitionIterator iterator, MorePartitions<? super PartitionIterator> more)
-
Uses of PartitionIterator in org.apache.cassandra.index
Methods in org.apache.cassandra.index that return types with arguments of type PartitionIterator 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.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. -
Uses of PartitionIterator in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal that return types with arguments of type PartitionIterator 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 unchangedjava.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator>
CassandraIndex. postProcessorFor(ReadCommand command)
No post processing of query results, just return them unchanged -
Uses of PartitionIterator in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi that return types with arguments of type PartitionIterator Modifier and Type Method Description java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator>
SASIIndex. postProcessorFor(ReadCommand command)
java.util.function.BiFunction<PartitionIterator,ReadCommand,PartitionIterator>
SASIIndex. postProcessorFor(ReadCommand command)
-
Uses of PartitionIterator in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return PartitionIterator Modifier and Type Method Description static PartitionIterator
StorageProxy. concatAndBlockOnRepair(java.util.List<PartitionIterator> iterators, java.util.List<ReadRepair<?,?>> repairs)
static PartitionIterator
StorageProxy. getRangeSlice(PartitionRangeReadCommand command, ConsistencyLevel consistencyLevel, long queryStartNanoTime)
static PartitionIterator
StorageProxy. read(SinglePartitionReadCommand.Group group, 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.Method parameters in org.apache.cassandra.service with type arguments of type PartitionIterator Modifier and Type Method Description static PartitionIterator
StorageProxy. concatAndBlockOnRepair(java.util.List<PartitionIterator> iterators, java.util.List<ReadRepair<?,?>> repairs)
-
Uses of PartitionIterator in org.apache.cassandra.service.pager
Classes in org.apache.cassandra.service.pager that implement PartitionIterator Modifier and Type Class 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.Methods in org.apache.cassandra.service.pager that return PartitionIterator Modifier and Type Method 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). -
Uses of PartitionIterator in org.apache.cassandra.service.reads
Fields in org.apache.cassandra.service.reads declared as PartitionIterator Modifier and Type Field Description protected PartitionIterator
AbstractReadExecutor. result
Methods in org.apache.cassandra.service.reads that return PartitionIterator Modifier and Type Method Description PartitionIterator
DataResolver. getData()
PartitionIterator
DigestResolver. getData()
PartitionIterator
AbstractReadExecutor. getResult()
PartitionIterator
DataResolver. resolve()
Methods in org.apache.cassandra.service.reads with parameters of type PartitionIterator Modifier and Type Method Description void
AbstractReadExecutor. setResult(PartitionIterator result)
-
Uses of PartitionIterator in org.apache.cassandra.service.reads.range
Methods in org.apache.cassandra.service.reads.range that return PartitionIterator Modifier and Type Method Description static PartitionIterator
RangeCommands. partitions(PartitionRangeReadCommand command, ConsistencyLevel consistencyLevel, long queryStartNanoTime)
-
Uses of PartitionIterator in org.apache.cassandra.service.reads.repair
Method parameters in org.apache.cassandra.service.reads.repair with type arguments of type PartitionIterator Modifier and Type Method 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.
-