Uses of Interface
org.apache.cassandra.db.partitions.PartitionIterator

Packages that use PartitionIterator

Package	Description
org.apache.cassandra.cql3
org.apache.cassandra.cql3.statements
org.apache.cassandra.db
org.apache.cassandra.db.filter
org.apache.cassandra.db.partitions
org.apache.cassandra.db.transform
org.apache.cassandra.index
org.apache.cassandra.index.sai.plan
org.apache.cassandra.index.sai.utils
org.apache.cassandra.service
org.apache.cassandra.service.pager
org.apache.cassandra.service.paxos
org.apache.cassandra.service.reads
org.apache.cassandra.service.reads.range
org.apache.cassandra.service.reads.repair

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(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, long nowInSec, boolean unmask, ClientState state)

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 state, Dispatcher.RequestTime requestTime)
PartitionIterator	PartitionRangeReadCommand.VirtualTablePartitionRangeReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
PartitionIterator	ReadQuery.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)	Executes the query at the provided consistency level.
PartitionIterator	SinglePartitionReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
PartitionIterator	SinglePartitionReadCommand.Group.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
PartitionIterator	SinglePartitionReadCommand.VirtualTableGroup.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
PartitionIterator	SinglePartitionReadCommand.VirtualTableSinglePartitionReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
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, long nowInSec, boolean countPartitionsWithOnlyStaticData, boolean enforceStrictLiveness)
PartitionIterator	RowFilter.filter(PartitionIterator iter, TableMetadata metadata, long 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, long nowInSec, boolean countPartitionsWithOnlyStaticData, boolean enforceStrictLiveness)
PartitionIterator	RowFilter.filter(PartitionIterator iter, TableMetadata metadata, long 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(List<PartitionIterator> iterators)
static PartitionIterator	PartitionIterators.doOnClose(PartitionIterator delegate, Runnable action)	Wraps the provided iterator to run a specified action on close.
static PartitionIterator	UnfilteredPartitionIterators.filter(UnfilteredPartitionIterator iterator, long nowInSec)
static PartitionIterator	PartitionIterators.loggingIterator(PartitionIterator iterator, 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 PartitionIterator	PartitionIterators.doOnClose(PartitionIterator delegate, 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, 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(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
final 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, 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, 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 PartitionIterator

Modifier and Type	Method	Description
default PartitionIterator	Index.Searcher.filterReplicaFilteringProtection(PartitionIterator fullResponse)	Replica filtering protection may fetch data that doesn't match query conditions.

Methods in org.apache.cassandra.index that return types with arguments of type PartitionIterator

Modifier and Type	Method	Description
default Function<PartitionIterator,PartitionIterator>	Index.QueryPlan.postProcessor(ReadCommand command)	Return a function which performs post processing on the results of a partition range read command.
default Function<PartitionIterator,PartitionIterator>	Index.QueryPlan.postProcessor(ReadCommand command)	Return a function which performs post processing on the results of a partition range read command.

Methods in org.apache.cassandra.index with parameters of type PartitionIterator

Modifier and Type	Method	Description
default PartitionIterator	Index.Searcher.filterReplicaFilteringProtection(PartitionIterator fullResponse)	Replica filtering protection may fetch data that doesn't match query conditions.

Uses of PartitionIterator in org.apache.cassandra.index.sai.plan

Methods in org.apache.cassandra.index.sai.plan that return PartitionIterator

Modifier and Type	Method	Description
PartitionIterator	StorageAttachedIndexSearcher.filterReplicaFilteringProtection(PartitionIterator fullResponse)

Methods in org.apache.cassandra.index.sai.plan that return types with arguments of type PartitionIterator

Modifier and Type	Method	Description
Function<PartitionIterator,PartitionIterator>	StorageAttachedIndexQueryPlan.postProcessor(ReadCommand command)	Called on coordinator after merging replica responses before returning to client
Function<PartitionIterator,PartitionIterator>	StorageAttachedIndexQueryPlan.postProcessor(ReadCommand command)	Called on coordinator after merging replica responses before returning to client

Methods in org.apache.cassandra.index.sai.plan with parameters of type PartitionIterator

Modifier and Type	Method	Description
PartitionIterator	StorageAttachedIndexSearcher.filterReplicaFilteringProtection(PartitionIterator fullResponse)

Uses of PartitionIterator in org.apache.cassandra.index.sai.utils

Classes in org.apache.cassandra.index.sai.utils that implement PartitionIterator

Modifier and Type	Class	Description
class	InMemoryPartitionIterator

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(List<PartitionIterator> iterators, List<ReadRepair<?,?>> repairs)
static PartitionIterator	StorageProxy.getRangeSlice(PartitionRangeReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)
static PartitionIterator	StorageProxy.read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)	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(List<PartitionIterator> iterators, 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
final 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, Dispatcher.RequestTime requestTime)
PartitionIterator	MultiPartitionPager.fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime)
PartitionIterator	QueryPager.fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime)	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.paxos

Methods in org.apache.cassandra.service.paxos that return PartitionIterator

Modifier and Type	Method	Description
static PartitionIterator	Paxos.read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyForConsensus, long deadline)
static PartitionIterator	Paxos.read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyForConsensus, Dispatcher.RequestTime requestTime)

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()
PartitionIterator	DataResolver.resolve(Runnable runOnShortRead)

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

Classes in org.apache.cassandra.service.reads.range that implement PartitionIterator

Modifier and Type	Class	Description
class	RangeCommandIterator
class	ScanAllRangesCommandIterator	A custom RangeCommandIterator that queries all replicas required by consistency level at once with data range specify in PartitionRangeReadCommand.

Methods in org.apache.cassandra.service.reads.range that return PartitionIterator

Modifier and Type	Method	Description
static PartitionIterator	RangeCommands.partitions(PartitionRangeReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)
protected PartitionIterator	ScanAllRangesCommandIterator.sendNextRequests()

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, Consumer<PartitionIterator> resultConsumer)
void	NoopReadRepair.startRepair(DigestResolver<E,P> digestResolver, Consumer<PartitionIterator> resultConsumer)
void	ReadRepair.startRepair(DigestResolver<E,P> digestResolver, Consumer<PartitionIterator> resultConsumer)	Called when the digests from the initial read don't match.