Uses of Interface
org.apache.cassandra.db.partitions.UnfilteredPartitionIterator
-
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db
Classes in org.apache.cassandra.db that implement UnfilteredPartitionIterator Modifier and Type Class Description static class
Memtable.MemtableUnfilteredPartitionIterator
Methods in org.apache.cassandra.db with parameters of type UnfilteredPartitionIterator Modifier and Type Method Description static ReadResponse
ReadResponse. createDataResponse(UnfilteredPartitionIterator data, ReadCommand command, org.apache.cassandra.db.RepairedDataInfo rdi)
static ReadResponse
ReadResponse. createDigestResponse(UnfilteredPartitionIterator data, ReadCommand command)
static ReadResponse
ReadResponse. createRemoteDataResponse(UnfilteredPartitionIterator data, java.nio.ByteBuffer repairedDataDigest, boolean isRepairedDigestConclusive, ReadCommand command, int version)
ReadResponse
ReadCommand. createResponse(UnfilteredPartitionIterator iterator, org.apache.cassandra.db.RepairedDataInfo rdi)
protected static java.nio.ByteBuffer
ReadResponse. makeDigest(UnfilteredPartitionIterator iterator, ReadCommand command)
protected UnfilteredPartitionIterator
ReadCommand. withoutPurgeableTombstones(UnfilteredPartitionIterator iterator, ColumnFamilyStore cfs, ReadExecutionController controller)
protected UnfilteredPartitionIterator
ReadCommand. withStateTracking(UnfilteredPartitionIterator iter)
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.compaction
Classes in org.apache.cassandra.db.compaction that implement UnfilteredPartitionIterator Modifier and Type Class Description class
CompactionIterator
Merge 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 UnfilteredPartitionIterator Modifier and Type Method Description UnfilteredPartitionIterator
DataLimits.Counter. applyTo(UnfilteredPartitionIterator partitions)
UnfilteredPartitionIterator
DataLimits. filter(UnfilteredPartitionIterator iter, int nowInSec, boolean countPartitionsWithOnlyStaticData)
UnfilteredPartitionIterator
RowFilter. filter(UnfilteredPartitionIterator iter, 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 UnfilteredPartitionIterator Modifier and Type Method Description UnfilteredPartitionIterator
DataLimits.Counter. applyTo(UnfilteredPartitionIterator partitions)
UnfilteredPartitionIterator
DataLimits. filter(UnfilteredPartitionIterator iter, int nowInSec, boolean countPartitionsWithOnlyStaticData)
UnfilteredPartitionIterator
RowFilter. filter(UnfilteredPartitionIterator iter, 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 UnfilteredPartitionIterator in org.apache.cassandra.db.partitions
Classes in org.apache.cassandra.db.partitions that implement UnfilteredPartitionIterator Modifier and Type Class Description class
AbstractUnfilteredPartitionIterator
class
SingletonUnfilteredPartitionIterator
Methods in org.apache.cassandra.db.partitions that return UnfilteredPartitionIterator Modifier and Type Method Description static UnfilteredPartitionIterator
UnfilteredPartitionIterators. concat(java.util.List<UnfilteredPartitionIterator> iterators)
UnfilteredPartitionIterator
UnfilteredPartitionIterators.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag)
static UnfilteredPartitionIterator
UnfilteredPartitionIterators. loggingIterator(UnfilteredPartitionIterator iterator, java.lang.String id, boolean fullDetails)
Wraps the provided iterator so it logs the returned rows/RT for debugging purposes.static UnfilteredPartitionIterator
UnfilteredPartitionIterators. merge(java.util.List<? extends UnfilteredPartitionIterator> iterators, UnfilteredPartitionIterators.MergeListener listener)
static UnfilteredPartitionIterator
UnfilteredPartitionIterators. mergeLazily(java.util.List<? extends UnfilteredPartitionIterator> iterators)
Methods in org.apache.cassandra.db.partitions with parameters of type UnfilteredPartitionIterator Modifier and Type Method Description static void
UnfilteredPartitionIterators. digest(UnfilteredPartitionIterator iterator, Digest digest, int version)
Digests the the provided iterator.static PartitionIterator
UnfilteredPartitionIterators. filter(UnfilteredPartitionIterator iterator, int nowInSec)
static UnfilteredRowIterator
UnfilteredPartitionIterators. getOnlyElement(UnfilteredPartitionIterator iter, SinglePartitionReadCommand command)
static UnfilteredPartitionIterator
UnfilteredPartitionIterators. loggingIterator(UnfilteredPartitionIterator iterator, java.lang.String id, boolean fullDetails)
Wraps the provided iterator so it logs the returned rows/RT for debugging purposes.void
UnfilteredPartitionIterators.Serializer. serialize(UnfilteredPartitionIterator iter, ColumnFilter selection, DataOutputPlus out, int version)
Method parameters in org.apache.cassandra.db.partitions with type arguments of type UnfilteredPartitionIterator Modifier and Type Method Description static UnfilteredPartitionIterator
UnfilteredPartitionIterators. concat(java.util.List<UnfilteredPartitionIterator> iterators)
static UnfilteredPartitionIterator
UnfilteredPartitionIterators. merge(java.util.List<? extends UnfilteredPartitionIterator> iterators, UnfilteredPartitionIterators.MergeListener listener)
static UnfilteredPartitionIterator
UnfilteredPartitionIterators. mergeLazily(java.util.List<? extends UnfilteredPartitionIterator> iterators)
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.repair
Classes in org.apache.cassandra.db.repair that implement UnfilteredPartitionIterator Modifier and Type Class Description class
CassandraValidationIterator
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.rows
Methods in org.apache.cassandra.db.rows with parameters of type UnfilteredPartitionIterator Modifier and Type Method Description static CloseableIterator<UnfilteredRowIterator>
ThrottledUnfilteredIterator. throttle(UnfilteredPartitionIterator partitionIterator, int maxBatchSize)
Splits aUnfilteredPartitionIterator
inUnfilteredRowIterator
batches with size no higher than maxBatchSize -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform that return UnfilteredPartitionIterator Modifier and Type Method Description static UnfilteredPartitionIterator
Transformation. apply(UnfilteredPartitionIterator iterator, Transformation<? super UnfilteredRowIterator> transformation)
static UnfilteredPartitionIterator
RTBoundCloser. close(UnfilteredPartitionIterator partitions)
static UnfilteredPartitionIterator
DuplicateRowChecker. duringCompaction(UnfilteredPartitionIterator iterator, OperationType type)
static UnfilteredPartitionIterator
MorePartitions. extend(UnfilteredPartitionIterator iterator, MorePartitions<? super UnfilteredPartitionIterator> more)
static UnfilteredPartitionIterator
RTBoundValidator. validate(UnfilteredPartitionIterator partitions, RTBoundValidator.Stage stage, boolean enforceIsClosed)
Method parameters in org.apache.cassandra.db.transform with type arguments of type UnfilteredPartitionIterator Modifier and Type Method Description static UnfilteredPartitionIterator
MorePartitions. 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 UnfilteredPartitionIterator Modifier and Type Method Description UnfilteredPartitionIterator
AbstractVirtualTable. select(DataRange dataRange, ColumnFilter columnFilter)
UnfilteredPartitionIterator
AbstractVirtualTable. select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter)
UnfilteredPartitionIterator
VirtualTable. select(DataRange dataRange, ColumnFilter columnFilter)
Selects the rows from a range of partitions.UnfilteredPartitionIterator
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 UnfilteredPartitionIterator Modifier and Type Method Description UnfilteredPartitionIterator
Index.Searcher. search(ReadExecutionController executionController)
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal that return UnfilteredPartitionIterator Modifier and Type Method Description protected abstract UnfilteredPartitionIterator
CassandraIndexSearcher. queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController)
UnfilteredPartitionIterator
CassandraIndexSearcher. search(ReadExecutionController executionController)
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index.internal.composites
Methods in org.apache.cassandra.index.internal.composites that return UnfilteredPartitionIterator Modifier and Type Method Description protected UnfilteredPartitionIterator
CompositesSearcher. 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 UnfilteredPartitionIterator Modifier and Type Method Description protected UnfilteredPartitionIterator
KeysSearcher. queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController)
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.index.sasi.plan
Methods in org.apache.cassandra.index.sasi.plan that return UnfilteredPartitionIterator Modifier and Type Method Description UnfilteredPartitionIterator
QueryPlan. execute(ReadExecutionController executionController)
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.io.sstable
Subinterfaces of UnfilteredPartitionIterator 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. -
Uses of UnfilteredPartitionIterator in org.apache.cassandra.io.sstable.format.big
Classes in org.apache.cassandra.io.sstable.format.big that implement UnfilteredPartitionIterator Modifier and Type Class Description class
BigTableScanner
static class
BigTableScanner.EmptySSTableScanner
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.repair
Classes in org.apache.cassandra.repair that implement UnfilteredPartitionIterator Modifier and Type Class Description class
ValidationPartitionIterator
-
Uses of UnfilteredPartitionIterator in org.apache.cassandra.service.reads
Methods in org.apache.cassandra.service.reads that return UnfilteredPartitionIterator Modifier and Type Method Description static UnfilteredPartitionIterator
ShortReadProtection. extend(Replica source, java.lang.Runnable preFetchCallback, UnfilteredPartitionIterator partitions, ReadCommand command, DataLimits.Counter mergedResultCounter, long queryStartNanoTime, boolean enforceStrictLiveness)
UnfilteredPartitionIterator
ShortReadPartitionsProtection. moreContents()
Methods in org.apache.cassandra.service.reads with parameters of type UnfilteredPartitionIterator Modifier and Type Method Description static UnfilteredPartitionIterator
ShortReadProtection. extend(Replica source, java.lang.Runnable preFetchCallback, UnfilteredPartitionIterator partitions, ReadCommand command, DataLimits.Counter mergedResultCounter, long queryStartNanoTime, boolean enforceStrictLiveness)
-