Uses of Interface
org.apache.cassandra.utils.CloseableIterator

Packages that use CloseableIterator

Package	Description
org.apache.cassandra.db.compaction
org.apache.cassandra.db.memtable
org.apache.cassandra.db.partitions
org.apache.cassandra.db.repair
org.apache.cassandra.db.rows
org.apache.cassandra.db.streaming	File transfer
org.apache.cassandra.db.transform
org.apache.cassandra.index.sai.disk
org.apache.cassandra.index.sai.disk.v1
org.apache.cassandra.index.sai.disk.v1.segment
org.apache.cassandra.index.sai.disk.v1.vector
org.apache.cassandra.index.sai.iterators
org.apache.cassandra.index.sai.memory
org.apache.cassandra.index.sai.plan
org.apache.cassandra.index.sai.utils
org.apache.cassandra.index.sasi.disk
org.apache.cassandra.io.sstable
org.apache.cassandra.io.sstable.format
org.apache.cassandra.io.sstable.format.big
org.apache.cassandra.io.sstable.format.bti
org.apache.cassandra.repair
org.apache.cassandra.service.pager
org.apache.cassandra.service.paxos.uncommitted
org.apache.cassandra.service.reads.range
org.apache.cassandra.utils

Uses of CloseableIterator in org.apache.cassandra.db.compaction

Classes in org.apache.cassandra.db.compaction that implement CloseableIterator

Modifier and Type	Class	Description
class	CompactionIterator	Merge multiple iterators over the content of sstable into a "compacted" iterator.

Uses of CloseableIterator in org.apache.cassandra.db.memtable

Classes in org.apache.cassandra.db.memtable that implement CloseableIterator

Modifier and Type	Class	Description
static class	ShardedSkipListMemtable.MemtableUnfilteredPartitionIterator

Uses of CloseableIterator in org.apache.cassandra.db.partitions

Subinterfaces of CloseableIterator in org.apache.cassandra.db.partitions

Modifier and Type	Interface	Description
interface	BasePartitionIterator<I extends BaseRowIterator<?>>
interface	PartitionIterator	An iterator over a number of (filtered) partition.
interface	UnfilteredPartitionIterator	An iterator over a number of unfiltered partitions (i.e.

Classes in org.apache.cassandra.db.partitions that implement CloseableIterator

Modifier and Type	Class	Description
class	AbstractUnfilteredPartitionIterator
class	SingletonUnfilteredPartitionIterator

Uses of CloseableIterator in org.apache.cassandra.db.repair

Classes in org.apache.cassandra.db.repair that implement CloseableIterator

Modifier and Type	Class	Description
class	CassandraValidationIterator

Uses of CloseableIterator in org.apache.cassandra.db.rows

Subinterfaces of CloseableIterator in org.apache.cassandra.db.rows

Modifier and Type	Interface	Description
interface	BaseRowIterator<U extends Unfiltered>	A common interface for Row and Unfiltered, that permits sharing of the (majority) common methods and functionality
interface	RowIterator	An iterator over rows belonging to a partition.
interface	UnfilteredRowIterator	An iterator over the rows of a given partition that also includes deletion informations.
interface	WrappingUnfilteredRowIterator	Abstract class to make writing unfiltered iterators that wrap another iterator easier.

Classes in org.apache.cassandra.db.rows that implement CloseableIterator

Modifier and Type	Class	Description
class	AbstractUnfilteredRowIterator
class	LazilyInitializedUnfilteredRowIterator	Abstract class to create UnfilteredRowIterator that lazily initializes itself.
class	RowAndDeletionMergeIterator	An iterator that merges a source of rows with the range tombstone and partition level deletion of a give partition.
class	ThrottledUnfilteredIterator	A utility class to split the given UnfilteredRowIterator into smaller chunks each having at most ThrottledUnfilteredIterator.throttle + 1 unfiltereds.
class	UnfilteredRowIteratorWithLowerBound	An unfiltered row iterator with a lower bound retrieved from either the global sstable statistics or the row index lower bounds (if available in the cache).

Methods in org.apache.cassandra.db.rows that return CloseableIterator

Modifier and Type	Method	Description
static CloseableIterator<UnfilteredRowIterator>	ThrottledUnfilteredIterator.throttle(UnfilteredPartitionIterator partitionIterator, int maxBatchSize)	Splits a UnfilteredPartitionIterator in UnfilteredRowIterator batches with size no higher than maxBatchSize

Uses of CloseableIterator in org.apache.cassandra.db.streaming

Classes in org.apache.cassandra.db.streaming that implement CloseableIterator

Modifier and Type	Class	Description
static class	CassandraStreamReader.StreamDeserializer

Uses of CloseableIterator in org.apache.cassandra.db.transform

Classes in org.apache.cassandra.db.transform that implement CloseableIterator

Modifier and Type	Class	Description
class	BasePartitions<R extends BaseRowIterator<?>,I extends BasePartitionIterator<? extends BaseRowIterator<?>>>
class	BaseRows<R extends Unfiltered,I extends BaseRowIterator<? extends Unfiltered>>
final class	FilteredPartitions
final class	FilteredRows

Uses of CloseableIterator in org.apache.cassandra.index.sai.disk

Methods in org.apache.cassandra.index.sai.disk that return types with arguments of type CloseableIterator

Modifier and Type	Method	Description
List<CloseableIterator<PrimaryKeyWithScore>>	EmptyIndex.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context)
abstract List<CloseableIterator<PrimaryKeyWithScore>>	SSTableIndex.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context)
List<CloseableIterator<PrimaryKeyWithScore>>	EmptyIndex.orderResultsBy(QueryContext context, List<PrimaryKey> results, Expression orderer)
abstract List<CloseableIterator<PrimaryKeyWithScore>>	SSTableIndex.orderResultsBy(QueryContext context, List<PrimaryKey> results, Expression orderer)

Uses of CloseableIterator in org.apache.cassandra.index.sai.disk.v1

Methods in org.apache.cassandra.index.sai.disk.v1 that return types with arguments of type CloseableIterator

Modifier and Type	Method	Description
List<CloseableIterator<PrimaryKeyWithScore>>	V1SSTableIndex.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context)
List<CloseableIterator<PrimaryKeyWithScore>>	V1SSTableIndex.orderResultsBy(QueryContext context, List<PrimaryKey> results, Expression orderer)

Uses of CloseableIterator in org.apache.cassandra.index.sai.disk.v1.segment

Methods in org.apache.cassandra.index.sai.disk.v1.segment that return CloseableIterator

Modifier and Type	Method	Description
CloseableIterator<PrimaryKeyWithScore>	IndexSegmentSearcher.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context)	Order the rows by the given expression.
CloseableIterator<PrimaryKeyWithScore>	Segment.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context)	Order the on-disk index synchronously and produce an iterator in score order
CloseableIterator<PrimaryKeyWithScore>	VectorIndexSegmentSearcher.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context)
CloseableIterator<PrimaryKeyWithScore>	Segment.orderResultsBy(QueryContext context, List<PrimaryKey> results, Expression orderer)
default CloseableIterator<PrimaryKeyWithScore>	SegmentOrdering.orderResultsBy(QueryContext queryContext, List<PrimaryKey> results, Expression orderer)	Reorder, limit, and put back into original order the results from a single sstable
CloseableIterator<PrimaryKeyWithScore>	VectorIndexSegmentSearcher.orderResultsBy(QueryContext context, List<PrimaryKey> results, Expression orderer)

Uses of CloseableIterator in org.apache.cassandra.index.sai.disk.v1.vector

Classes in org.apache.cassandra.index.sai.disk.v1.vector that implement CloseableIterator

Modifier and Type	Class	Description
class	AutoResumingNodeScoreIterator	An iterator over SearchResult.NodeScore backed by a SearchResult that resumes search when the backing SearchResult is exhausted.
class	BruteForceRowIdIterator	An iterator over RowIdWithScore that lazily consumes from a NeighborQueue of approximate scores.
class	NeighborQueueRowIdIterator	An iterator over RowIdWithScore that lazily consumes a NeighborQueue.
class	NodeScoreToRowIdWithScoreIterator	An iterator over RowIdWithScore sorted by score descending.
class	RowIdToPrimaryKeyWithScoreIterator	An iterator over scored primary keys ordered by the score descending Not skippable.

Methods in org.apache.cassandra.index.sai.disk.v1.vector that return CloseableIterator

Modifier and Type	Method	Description
CloseableIterator<RowIdWithScore>	DiskAnn.search(float[] queryVector, int topK, int limit, io.github.jbellis.jvector.util.Bits acceptBits, IntConsumer nodesVisitedConsumer)
CloseableIterator<io.github.jbellis.jvector.graph.SearchResult.NodeScore>	OnHeapGraph.search(float[] queryVector, int limit, io.github.jbellis.jvector.util.Bits toAccept)

Constructors in org.apache.cassandra.index.sai.disk.v1.vector with parameters of type CloseableIterator

Modifier	Constructor	Description
	NodeScoreToRowIdWithScoreIterator(CloseableIterator<io.github.jbellis.jvector.graph.SearchResult.NodeScore> nodeScores, OnDiskOrdinalsMap.RowIdsView rowIdsView)
	RowIdToPrimaryKeyWithScoreIterator(ColumnMetadata column, PrimaryKeyMap.Factory primaryKeyMapFactory, CloseableIterator<RowIdWithScore> scoredRowIdIterator, long segmentRowIdOffset)

Uses of CloseableIterator in org.apache.cassandra.index.sai.iterators

Classes in org.apache.cassandra.index.sai.iterators that implement CloseableIterator

Modifier and Type	Class	Description
class	PriorityQueueIterator<T>	An iterator over a priority queue.

Uses of CloseableIterator in org.apache.cassandra.index.sai.memory

Methods in org.apache.cassandra.index.sai.memory that return CloseableIterator

Modifier and Type	Method	Description
CloseableIterator<PrimaryKeyWithScore>	MemtableIndex.orderBy(QueryContext queryContext, Expression orderer, AbstractBounds<PartitionPosition> keyRange)
CloseableIterator<PrimaryKeyWithScore>	MemtableOrdering.orderBy(QueryContext queryContext, Expression orderer, AbstractBounds<PartitionPosition> keyRange)	Order the index based on the given orderer (expression).
CloseableIterator<PrimaryKeyWithScore>	TrieMemoryIndex.orderBy(QueryContext queryContext, Expression orderer, AbstractBounds<PartitionPosition> keyRange)
CloseableIterator<PrimaryKeyWithScore>	VectorMemoryIndex.orderBy(QueryContext queryContext, Expression expr, AbstractBounds<PartitionPosition> keyRange)
CloseableIterator<PrimaryKeyWithScore>	MemtableIndex.orderResultsBy(QueryContext queryContext, List<PrimaryKey> results, Expression orderer)
CloseableIterator<PrimaryKeyWithScore>	MemtableOrdering.orderResultsBy(QueryContext context, List<PrimaryKey> results, Expression orderer)	Order the given list of PrimaryKey results corresponding to the given orderer.
CloseableIterator<PrimaryKeyWithScore>	TrieMemoryIndex.orderResultsBy(QueryContext context, List<PrimaryKey> results, Expression orderer)
CloseableIterator<PrimaryKeyWithScore>	VectorMemoryIndex.orderResultsBy(QueryContext queryContext, List<PrimaryKey> results, Expression orderer)

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

Classes in org.apache.cassandra.index.sai.plan that implement CloseableIterator

Modifier and Type	Class	Description
class	StorageAttachedIndexSearcher.ScoreOrderedResultRetriever	A result retriever that consumes an iterator primary keys sorted by some score, materializes the row for each primary key (currently, each primary key is required to be fully qualified and should only point to one row), apply the filter tree to the row to test that the real row satisfies the WHERE clause, and finally tests that the row is valid for the ORDER BY clause.

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

Modifier and Type	Method	Description
CloseableIterator<PrimaryKeyWithScore>	QueryController.getTopKRows(KeyRangeIterator source, QueryViewBuilder.QueryExpressionView queryExpressionView)
CloseableIterator<PrimaryKeyWithScore>	QueryController.getTopKRows(QueryViewBuilder.QueryExpressionView queryExpressionView)

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

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

Modifier and Type	Class	Description
class	InMemoryPartitionIterator
class	InMemoryUnfilteredPartitionIterator
class	MergePrimaryKeyWithScoreIterator

Constructor parameters in org.apache.cassandra.index.sai.utils with type arguments of type CloseableIterator

Modifier	Constructor	Description
	MergePrimaryKeyWithScoreIterator(Collection<CloseableIterator<PrimaryKeyWithScore>> iterators)

Uses of CloseableIterator in org.apache.cassandra.index.sasi.disk

Classes in org.apache.cassandra.index.sasi.disk that implement CloseableIterator

Modifier and Type	Class	Description
static class	AbstractTokenTreeBuilder.LevelIterator

Uses of CloseableIterator in org.apache.cassandra.io.sstable

Subinterfaces of CloseableIterator in org.apache.cassandra.io.sstable

Modifier and Type	Interface	Description
interface	ISSTableScanner	An ISSTableScanner is an abstraction allowing multiple SSTableScanners to be chained together under the hood.

Classes in org.apache.cassandra.io.sstable that implement CloseableIterator

Modifier and Type	Class	Description
class	AbstractSSTableIterator<RIE extends AbstractRowIndexEntry>
class	EmptySSTableScanner
class	KeyIterator
class	ReducingKeyIterator	Caller must acquire and release references to the sstables used here.
class	SSTableIdentityIterator
class	SSTableSimpleIterator	Utility class to handle deserializing atom from sstables.
static class	SSTableSimpleIterator.EmptySSTableSimpleIterator

Uses of CloseableIterator in org.apache.cassandra.io.sstable.format

Classes in org.apache.cassandra.io.sstable.format that implement CloseableIterator

Modifier and Type	Class	Description
class	SSTableScanner<S extends SSTableReader,E extends AbstractRowIndexEntry,I extends SSTableScanner<S,E,I>.BaseKeyScanningIterator>
class	SSTableScanner.BaseKeyScanningIterator
class	SSTableSimpleScanner

Uses of CloseableIterator in org.apache.cassandra.io.sstable.format.big

Classes in org.apache.cassandra.io.sstable.format.big that implement CloseableIterator

Modifier and Type	Class	Description
class	BigTableScanner
protected class	BigTableScanner.BigScanningIterator
class	SSTableIterator	A Cell Iterator over SSTable
class	SSTableReversedIterator	A Cell Iterator in reversed clustering order over SSTable

Uses of CloseableIterator in org.apache.cassandra.io.sstable.format.bti

Classes in org.apache.cassandra.io.sstable.format.bti that implement CloseableIterator

Modifier and Type	Class	Description
class	BtiTableScanner
protected class	BtiTableScanner.BtiScanningIterator

Uses of CloseableIterator in org.apache.cassandra.repair

Classes in org.apache.cassandra.repair that implement CloseableIterator

Modifier and Type	Class	Description
class	ValidationPartitionIterator

Uses of CloseableIterator in org.apache.cassandra.service.pager

Classes in org.apache.cassandra.service.pager that implement CloseableIterator

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.

Uses of CloseableIterator in org.apache.cassandra.service.paxos.uncommitted

Methods in org.apache.cassandra.service.paxos.uncommitted that return CloseableIterator

Modifier and Type	Method	Description
CloseableIterator<PaxosKeyState>	PaxosUncommittedIndex.flushIterator(Memtable flushing)
CloseableIterator<PaxosKeyState>	PaxosUncommittedTracker.UpdateSupplier.flushIterator(Memtable paxos)
static CloseableIterator<PaxosKeyState>	PaxosKeyState.mergeUncommitted(CloseableIterator<PaxosKeyState>... iterators)
CloseableIterator<PaxosKeyState>	PaxosUncommittedIndex.repairIterator(TableId tableId, Collection<Range<Token>> ranges)
CloseableIterator<PaxosKeyState>	PaxosUncommittedTracker.UpdateSupplier.repairIterator(TableId tableId, Collection<Range<Token>> ranges)
static CloseableIterator<UncommittedPaxosKey>	PaxosKeyState.toUncommittedInfo(CloseableIterator<PaxosKeyState> iter)
CloseableIterator<UncommittedPaxosKey>	PaxosUncommittedTracker.uncommittedKeyIterator(TableId tableId, Collection<Range<Token>> ranges)

Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type CloseableIterator

Modifier and Type	Method	Description
static CloseableIterator<PaxosKeyState>	PaxosKeyState.mergeUncommitted(CloseableIterator<PaxosKeyState>... iterators)
static CloseableIterator<UncommittedPaxosKey>	PaxosKeyState.toUncommittedInfo(CloseableIterator<PaxosKeyState> iter)

Uses of CloseableIterator in org.apache.cassandra.service.reads.range

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

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.

Uses of CloseableIterator in org.apache.cassandra.utils

Subinterfaces of CloseableIterator in org.apache.cassandra.utils

Modifier and Type	Interface	Description
interface	IMergeIterator<In,Out>

Classes in org.apache.cassandra.utils that implement CloseableIterator

Modifier and Type	Class	Description
class	AbstractIterator<V>
class	MergeIterator<In,Out>	Merges sorted input iterators which individually contain unique items.
static class	MerkleTree.TreeRangeIterator	Returns the leaf (range) of a given tree in increasing order.

Methods in org.apache.cassandra.utils that return CloseableIterator

Modifier and Type	Method	Description
static <T> CloseableIterator<T>	FBUtilities.closeableIterator(Iterator<T> iterator)
static <T> CloseableIterator<T>	CloseableIterator.empty()
static <T> CloseableIterator<T>	CloseableIterator.wrap(Iterator<T> iter)