Modifier and Type | Class and Description |
---|---|
static class |
Memtable.MemtableUnfilteredPartitionIterator |
Modifier and Type | Method and Description |
---|---|
static ReadResponse |
ReadResponse.createDataResponse(UnfilteredPartitionIterator data,
ReadCommand command) |
static ReadResponse |
ReadResponse.createDigestResponse(UnfilteredPartitionIterator data,
ReadCommand command) |
static ReadResponse |
ReadResponse.createRemoteDataResponse(UnfilteredPartitionIterator data,
ReadCommand command) |
ReadResponse |
ReadCommand.createResponse(UnfilteredPartitionIterator iterator) |
protected static java.nio.ByteBuffer |
ReadResponse.makeDigest(UnfilteredPartitionIterator iterator,
ReadCommand command) |
protected UnfilteredPartitionIterator |
ReadCommand.withoutPurgeableTombstones(UnfilteredPartitionIterator iterator,
ColumnFamilyStore cfs) |
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) |
abstract 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) |
abstract 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,
CFMetaData metadata,
ColumnFilter selection,
SerializationHelper.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,
int nowInSec,
UnfilteredPartitionIterators.MergeListener listener) |
static UnfilteredPartitionIterator |
UnfilteredPartitionIterators.mergeLazily(java.util.List<? extends UnfilteredPartitionIterator> iterators,
int nowInSec) |
Modifier and Type | Method and Description |
---|---|
static void |
UnfilteredPartitionIterators.digest(ReadCommand command,
UnfilteredPartitionIterator iterator,
java.security.MessageDigest 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,
int nowInSec,
UnfilteredPartitionIterators.MergeListener listener) |
static UnfilteredPartitionIterator |
UnfilteredPartitionIterators.mergeLazily(java.util.List<? extends UnfilteredPartitionIterator> iterators,
int nowInSec) |
Modifier and Type | Method and Description |
---|---|
static UnfilteredPartitionIterator |
Transformation.apply(UnfilteredPartitionIterator iterator,
Transformation<? super UnfilteredRowIterator> transformation) |
static UnfilteredPartitionIterator |
MorePartitions.extend(UnfilteredPartitionIterator iterator,
MorePartitions<? super UnfilteredPartitionIterator> more) |
Modifier and Type | Method and Description |
---|---|
static UnfilteredPartitionIterator |
Transformation.apply(UnfilteredPartitionIterator iterator,
Transformation<? super UnfilteredRowIterator> transformation) |
static UnfilteredPartitionIterator |
MorePartitions.extend(UnfilteredPartitionIterator iterator,
MorePartitions<? super UnfilteredPartitionIterator> more) |
static FilteredPartitions |
FilteredPartitions.filter(UnfilteredPartitionIterator iterator,
Filter filter) |
static FilteredPartitions |
FilteredPartitions.filter(UnfilteredPartitionIterator iterator,
int nowInSecs)
Filter any RangeTombstoneMarker from the iterator's iterators, transforming it into a PartitionIterator.
|
Modifier and Type | Method and Description |
---|---|
static UnfilteredPartitionIterator |
MorePartitions.extend(UnfilteredPartitionIterator iterator,
MorePartitions<? super UnfilteredPartitionIterator> more) |
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 |
Copyright © 2018 The Apache Software Foundation