Modifier and Type | Class and Description |
---|---|
static class |
Memtable.MemtableUnfilteredPartitionIterator |
Modifier and Type | Method and 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) |
Modifier and Type | Class and Description |
---|---|
class |
CompactionIterator
Merge multiple iterators over the content of sstable into a "compacted" iterator.
|
Modifier and Type | Method and Description |
---|---|
UnfilteredPartitionIterator |
DataLimits.Counter.applyTo(UnfilteredPartitionIterator partitions) |
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.
|
UnfilteredPartitionIterator |
DataLimits.filter(UnfilteredPartitionIterator iter,
int nowInSec,
boolean countPartitionsWithOnlyStaticData) |
Modifier and Type | Method and Description |
---|---|
UnfilteredPartitionIterator |
DataLimits.Counter.applyTo(UnfilteredPartitionIterator partitions) |
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.
|
UnfilteredPartitionIterator |
DataLimits.filter(UnfilteredPartitionIterator iter,
int nowInSec,
boolean countPartitionsWithOnlyStaticData) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractUnfilteredPartitionIterator |
class |
SingletonUnfilteredPartitionIterator |
Modifier and Type | Method and 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) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and 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) |
Modifier and Type | Class and Description |
---|---|
class |
CassandraValidationIterator |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<UnfilteredRowIterator> |
ThrottledUnfilteredIterator.throttle(UnfilteredPartitionIterator partitionIterator,
int maxBatchSize)
Splits a
UnfilteredPartitionIterator in UnfilteredRowIterator batches with size no higher than
maxBatchSize |
Modifier and Type | Method and 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) |
Modifier and Type | Method and Description |
---|---|
static UnfilteredPartitionIterator |
MorePartitions.extend(UnfilteredPartitionIterator iterator,
MorePartitions<? super UnfilteredPartitionIterator> more) |
Modifier and Type | Method and Description |
---|---|
UnfilteredPartitionIterator |
AbstractVirtualTable.select(DataRange dataRange,
ColumnFilter columnFilter) |
UnfilteredPartitionIterator |
VirtualTable.select(DataRange dataRange,
ColumnFilter columnFilter)
Selects the rows from a range of partitions.
|
UnfilteredPartitionIterator |
AbstractVirtualTable.select(DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter,
ColumnFilter columnFilter) |
UnfilteredPartitionIterator |
VirtualTable.select(DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter,
ColumnFilter columnFilter)
Selects the rows from a single partition.
|
Modifier and Type | Method and Description |
---|---|
UnfilteredPartitionIterator |
Index.Searcher.search(ReadExecutionController executionController) |
Modifier and Type | Method and Description |
---|---|
protected abstract UnfilteredPartitionIterator |
CassandraIndexSearcher.queryDataFromIndex(DecoratedKey indexKey,
RowIterator indexHits,
ReadCommand command,
ReadExecutionController executionController) |
UnfilteredPartitionIterator |
CassandraIndexSearcher.search(ReadExecutionController executionController) |
Modifier and Type | Method and Description |
---|---|
protected UnfilteredPartitionIterator |
CompositesSearcher.queryDataFromIndex(DecoratedKey indexKey,
RowIterator indexHits,
ReadCommand command,
ReadExecutionController executionController) |
Modifier and Type | Method and Description |
---|---|
protected UnfilteredPartitionIterator |
KeysSearcher.queryDataFromIndex(DecoratedKey indexKey,
RowIterator indexHits,
ReadCommand command,
ReadExecutionController executionController) |
Modifier and Type | Method and Description |
---|---|
UnfilteredPartitionIterator |
QueryPlan.execute(ReadExecutionController executionController) |
Modifier and Type | Interface and Description |
---|---|
interface |
ISSTableScanner
An ISSTableScanner is an abstraction allowing multiple SSTableScanners to be
chained together under the hood.
|
Modifier and Type | Class and Description |
---|---|
class |
BigTableScanner |
static class |
BigTableScanner.EmptySSTableScanner |
Modifier and Type | Class and Description |
---|---|
class |
ValidationPartitionIterator |
Modifier and Type | Method and 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() |
Modifier and Type | Method and Description |
---|---|
static UnfilteredPartitionIterator |
ShortReadProtection.extend(Replica source,
java.lang.Runnable preFetchCallback,
UnfilteredPartitionIterator partitions,
ReadCommand command,
DataLimits.Counter mergedResultCounter,
long queryStartNanoTime,
boolean enforceStrictLiveness) |
Copyright © 2009-2022 The Apache Software Foundation