Uses of Interface
org.apache.cassandra.db.partitions.UnfilteredPartitionIterator
Packages that use UnfilteredPartitionIterator
Package
Description
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionPartitionRangeReadCommand.VirtualTablePartitionRangeReadCommand.executeLocally(ReadExecutionController executionController) ReadCommand.executeLocally(ReadExecutionController executionController) Executes this command on the local host.ReadQuery.executeLocally(ReadExecutionController executionController) Execute the query locally.SinglePartitionReadCommand.VirtualTableSinglePartitionReadCommand.executeLocally(ReadExecutionController executionController) SinglePartitionReadQuery.Group.executeLocally(ReadExecutionController executionController) abstract UnfilteredPartitionIteratorReadResponse.makeIterator(ReadCommand command) PartitionRangeReadCommand.queryStorage(ColumnFamilyStore cfs, ReadExecutionController controller) protected abstract UnfilteredPartitionIteratorReadCommand.queryStorage(ColumnFamilyStore cfs, ReadExecutionController executionController) protected UnfilteredPartitionIteratorSinglePartitionReadCommand.queryStorage(ColumnFamilyStore cfs, ReadExecutionController executionController) static UnfilteredPartitionIteratorEmptyIterators.unfilteredPartition(TableMetadata metadata) protected UnfilteredPartitionIteratorReadCommand.withoutPurgeableTombstones(UnfilteredPartitionIterator iterator, ColumnFamilyStore cfs, ReadExecutionController controller) Methods in org.apache.cassandra.db with parameters of type UnfilteredPartitionIteratorModifier and TypeMethodDescriptionstatic ReadResponseReadResponse.createDataResponse(UnfilteredPartitionIterator data, ReadCommand command, org.apache.cassandra.db.RepairedDataInfo rdi) static ReadResponseReadResponse.createDigestResponse(UnfilteredPartitionIterator data, ReadCommand command) static ReadResponseReadResponse.createRemoteDataResponse(UnfilteredPartitionIterator data, ByteBuffer repairedDataDigest, boolean isRepairedDigestConclusive, ReadCommand command, int version) ReadCommand.createResponse(UnfilteredPartitionIterator iterator, org.apache.cassandra.db.RepairedDataInfo rdi) static ReadResponseReadResponse.createSimpleDataResponse(UnfilteredPartitionIterator data, ColumnFilter selection) protected static ByteBufferReadResponse.makeDigest(UnfilteredPartitionIterator iterator, ReadCommand command) protected UnfilteredPartitionIteratorReadCommand.withoutPurgeableTombstones(UnfilteredPartitionIterator iterator, ColumnFamilyStore cfs, ReadExecutionController controller) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.compaction
Classes in org.apache.cassandra.db.compaction that implement UnfilteredPartitionIteratorModifier and TypeClassDescriptionclassMerge multiple iterators over the content of sstable into a "compacted" iterator. -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionDataLimits.Counter.applyTo(UnfilteredPartitionIterator partitions) DataLimits.filter(UnfilteredPartitionIterator iter, long nowInSec, boolean countPartitionsWithOnlyStaticData) RowFilter.filter(UnfilteredPartitionIterator iter, 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 UnfilteredPartitionIteratorModifier and TypeMethodDescriptionDataLimits.Counter.applyTo(UnfilteredPartitionIterator partitions) DataLimits.filter(UnfilteredPartitionIterator iter, long nowInSec, boolean countPartitionsWithOnlyStaticData) RowFilter.filter(UnfilteredPartitionIterator iter, 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 UnfilteredPartitionIterator in org.apache.cassandra.db.memtable
Classes in org.apache.cassandra.db.memtable that implement UnfilteredPartitionIteratorModifier and TypeClassDescriptionstatic class -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.partitions
Classes in org.apache.cassandra.db.partitions that implement UnfilteredPartitionIteratorModifier and TypeClassDescriptionclassclassMethods in org.apache.cassandra.db.partitions that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorUnfilteredPartitionIterators.concat(List<UnfilteredPartitionIterator> iterators) UnfilteredPartitionIterators.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag) static UnfilteredPartitionIteratorUnfilteredPartitionIterators.loggingIterator(UnfilteredPartitionIterator iterator, String id, boolean fullDetails) Wraps the provided iterator so it logs the returned rows/RT for debugging purposes.static UnfilteredPartitionIteratorUnfilteredPartitionIterators.merge(List<? extends UnfilteredPartitionIterator> iterators, UnfilteredPartitionIterators.MergeListener listener) static UnfilteredPartitionIteratorUnfilteredPartitionIterators.mergeLazily(List<? extends UnfilteredPartitionIterator> iterators) Methods in org.apache.cassandra.db.partitions with parameters of type UnfilteredPartitionIteratorModifier and TypeMethodDescriptionstatic voidUnfilteredPartitionIterators.digest(UnfilteredPartitionIterator iterator, Digest digest, int version) Digests the the provided iterator.static PartitionIteratorUnfilteredPartitionIterators.filter(UnfilteredPartitionIterator iterator, long nowInSec) static UnfilteredRowIteratorUnfilteredPartitionIterators.getOnlyElement(UnfilteredPartitionIterator iter, SinglePartitionReadCommand command) static UnfilteredPartitionIteratorUnfilteredPartitionIterators.loggingIterator(UnfilteredPartitionIterator iterator, String id, boolean fullDetails) Wraps the provided iterator so it logs the returned rows/RT for debugging purposes.voidUnfilteredPartitionIterators.Serializer.serialize(UnfilteredPartitionIterator iter, ColumnFilter selection, DataOutputPlus out, int version) Method parameters in org.apache.cassandra.db.partitions with type arguments of type UnfilteredPartitionIteratorModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorUnfilteredPartitionIterators.concat(List<UnfilteredPartitionIterator> iterators) static UnfilteredPartitionIteratorUnfilteredPartitionIterators.merge(List<? extends UnfilteredPartitionIterator> iterators, UnfilteredPartitionIterators.MergeListener listener) static UnfilteredPartitionIteratorUnfilteredPartitionIterators.mergeLazily(List<? extends UnfilteredPartitionIterator> iterators) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.repair
Classes in org.apache.cassandra.db.repair that implement UnfilteredPartitionIterator -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.rows
Methods in org.apache.cassandra.db.rows that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionUnfilteredSource.partitionIterator(ColumnFilter columnFilter, DataRange dataRange, SSTableReadsListener listener) Returns a partition iterator for the given data range.Methods in org.apache.cassandra.db.rows with parameters of type UnfilteredPartitionIteratorModifier and TypeMethodDescriptionThrottledUnfilteredIterator.throttle(UnfilteredPartitionIterator partitionIterator, int maxBatchSize) Splits aUnfilteredPartitionIteratorinUnfilteredRowIteratorbatches with size no higher than maxBatchSize -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorTransformation.apply(UnfilteredPartitionIterator iterator, Transformation<? super UnfilteredRowIterator> transformation) static UnfilteredPartitionIteratorRTBoundCloser.close(UnfilteredPartitionIterator partitions) static UnfilteredPartitionIteratorDuplicateRowChecker.duringCompaction(UnfilteredPartitionIterator iterator, OperationType type) static UnfilteredPartitionIteratorMorePartitions.extend(UnfilteredPartitionIterator iterator, MorePartitions<? super UnfilteredPartitionIterator> more) static UnfilteredPartitionIteratorRTBoundValidator.validate(UnfilteredPartitionIterator partitions, RTBoundValidator.Stage stage, boolean enforceIsClosed) Methods in org.apache.cassandra.db.transform with parameters of type UnfilteredPartitionIteratorModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorTransformation.apply(UnfilteredPartitionIterator iterator, Transformation<? super UnfilteredRowIterator> transformation) static UnfilteredPartitionIteratorRTBoundCloser.close(UnfilteredPartitionIterator partitions) static UnfilteredPartitionIteratorDuplicateRowChecker.duringCompaction(UnfilteredPartitionIterator iterator, OperationType type) static UnfilteredPartitionIteratorMorePartitions.extend(UnfilteredPartitionIterator iterator, MorePartitions<? super UnfilteredPartitionIterator> more) static FilteredPartitionsFilteredPartitions.filter(UnfilteredPartitionIterator iterator, long nowInSecs) Filter any RangeTombstoneMarker from the iterator's iterators, transforming it into a PartitionIterator.static FilteredPartitionsFilteredPartitions.filter(UnfilteredPartitionIterator iterator, Filter filter) static UnfilteredPartitionIteratorRTBoundValidator.validate(UnfilteredPartitionIterator partitions, RTBoundValidator.Stage stage, boolean enforceIsClosed) Method parameters in org.apache.cassandra.db.transform with type arguments of type UnfilteredPartitionIteratorModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorMorePartitions.extend(UnfilteredPartitionIterator iterator, MorePartitions<? super UnfilteredPartitionIterator> more) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.virtual
Methods in org.apache.cassandra.db.virtual that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionAbstractVirtualTable.select(DataRange dataRange, ColumnFilter columnFilter) AbstractVirtualTable.select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter) VirtualTable.select(DataRange dataRange, ColumnFilter columnFilter) Selects the rows from a range of partitions.VirtualTable.select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter) Selects the rows from a single partition. -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index
Methods in org.apache.cassandra.index that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionIndex.Searcher.search(ReadExecutionController executionController) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionprotected abstract UnfilteredPartitionIteratorCassandraIndexSearcher.queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) CassandraIndexSearcher.search(ReadExecutionController executionController) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index.internal.composites
Methods in org.apache.cassandra.index.internal.composites that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionprotected UnfilteredPartitionIteratorCompositesSearcher.queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index.internal.keys
Methods in org.apache.cassandra.index.internal.keys that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionprotected UnfilteredPartitionIteratorKeysSearcher.queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index.sai.plan
Classes in org.apache.cassandra.index.sai.plan that implement UnfilteredPartitionIteratorModifier and TypeClassDescriptionclassA 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 UnfilteredPartitionIteratorModifier and TypeMethodDescriptionStorageAttachedIndexSearcher.search(ReadExecutionController executionController) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index.sai.utils
Classes in org.apache.cassandra.index.sai.utils that implement UnfilteredPartitionIterator -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index.sasi.plan
Methods in org.apache.cassandra.index.sasi.plan that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionSASIIndexSearcher.search(ReadExecutionController executionController) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.io.sstable
Subinterfaces of UnfilteredPartitionIterator in org.apache.cassandra.io.sstableModifier and TypeInterfaceDescriptioninterfaceAn ISSTableScanner is an abstraction allowing multiple SSTableScanners to be chained together under the hood.Classes in org.apache.cassandra.io.sstable that implement UnfilteredPartitionIterator -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.io.sstable.format
Classes in org.apache.cassandra.io.sstable.format that implement UnfilteredPartitionIteratorModifier and TypeClassDescriptionclassSSTableScanner<S extends SSTableReader,E extends AbstractRowIndexEntry, I extends SSTableScanner<S, E, I>.BaseKeyScanningIterator> class -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.io.sstable.format.big
Classes in org.apache.cassandra.io.sstable.format.big that implement UnfilteredPartitionIterator -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.io.sstable.format.bti
Classes in org.apache.cassandra.io.sstable.format.bti that implement UnfilteredPartitionIteratorMethods in org.apache.cassandra.io.sstable.format.bti that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionBtiTableReader.partitionIterator(ColumnFilter columnFilter, DataRange dataRange, SSTableReadsListener listener) -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.repair
Classes in org.apache.cassandra.repair that implement UnfilteredPartitionIterator -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.service.reads
Methods in org.apache.cassandra.service.reads that return UnfilteredPartitionIteratorModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorShortReadProtection.extend(Replica source, Runnable preFetchCallback, UnfilteredPartitionIterator partitions, ReadCommand command, DataLimits.Counter mergedResultCounter, Dispatcher.RequestTime requestTime, boolean enforceStrictLiveness) ShortReadPartitionsProtection.moreContents()Methods in org.apache.cassandra.service.reads with parameters of type UnfilteredPartitionIteratorModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorShortReadProtection.extend(Replica source, Runnable preFetchCallback, UnfilteredPartitionIterator partitions, ReadCommand command, DataLimits.Counter mergedResultCounter, Dispatcher.RequestTime requestTime, boolean enforceStrictLiveness)