Modifier and Type | Method and Description |
---|---|
protected UnfilteredRowIterator |
ReadCommand.CheckForAbort.applyToPartition(UnfilteredRowIterator partition) |
UnfilteredRowIterator |
StorageHook.makeRowIterator(ColumnFamilyStore cfs,
SSTableReader sstable,
DecoratedKey key,
Slices slices,
ColumnFilter selectedColumns,
boolean reversed,
SSTableReadsListener listener) |
UnfilteredRowIterator |
Memtable.MemtableUnfilteredPartitionIterator.next() |
UnfilteredRowIterator |
SinglePartitionReadCommand.queryMemtableAndDisk(ColumnFamilyStore cfs,
ReadExecutionController executionController)
Queries both memtable and sstables to fetch the result of this query.
|
static UnfilteredRowIterator |
EmptyIterators.unfilteredRow(CFMetaData metadata,
DecoratedKey partitionKey,
boolean isReverseOrder) |
static UnfilteredRowIterator |
EmptyIterators.unfilteredRow(CFMetaData metadata,
DecoratedKey partitionKey,
boolean isReverseOrder,
Row staticRow,
DeletionTime partitionDeletion) |
Modifier and Type | Method and Description |
---|---|
protected UnfilteredRowIterator |
ReadCommand.CheckForAbort.applyToPartition(UnfilteredRowIterator partition) |
void |
ColumnIndex.buildRowIndex(UnfilteredRowIterator iterator) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSSTableIterator |
class |
SSTableIterator
A Cell Iterator over SSTable
|
class |
SSTableReversedIterator
A Cell Iterator in reversed clustering order over SSTable
|
Modifier and Type | Method and Description |
---|---|
UnfilteredRowIterator |
CompactionIterator.next() |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<UnfilteredRowIterator> |
CompactionController.shadowSources(DecoratedKey key,
boolean tombstoneOnly) |
Modifier and Type | Method and Description |
---|---|
boolean |
CompactionAwareWriter.append(UnfilteredRowIterator partition)
Writes a partition in an implementation specific way
|
protected abstract boolean |
CompactionAwareWriter.realAppend(UnfilteredRowIterator partition) |
boolean |
DefaultCompactionWriter.realAppend(UnfilteredRowIterator partition) |
boolean |
MajorLeveledCompactionWriter.realAppend(UnfilteredRowIterator partition) |
protected boolean |
MaxSSTableSizeWriter.realAppend(UnfilteredRowIterator partition) |
boolean |
SplittingSizeTieredCompactionWriter.realAppend(UnfilteredRowIterator partition) |
Modifier and Type | Method and Description |
---|---|
UnfilteredRowIterator |
DataLimits.Counter.applyTo(UnfilteredRowIterator partition) |
UnfilteredRowIterator |
DataLimits.filter(UnfilteredRowIterator iter,
int nowInSec,
boolean countPartitionsWithOnlyStaticData) |
UnfilteredRowIterator |
ClusteringIndexFilter.filterNotIndexed(ColumnFilter columnFilter,
UnfilteredRowIterator iterator)
Returns an iterator that only returns the rows of the provided iterator that this filter selects.
|
UnfilteredRowIterator |
ClusteringIndexNamesFilter.filterNotIndexed(ColumnFilter columnFilter,
UnfilteredRowIterator iterator) |
UnfilteredRowIterator |
ClusteringIndexSliceFilter.filterNotIndexed(ColumnFilter columnFilter,
UnfilteredRowIterator iterator) |
UnfilteredRowIterator |
ClusteringIndexFilter.getUnfilteredRowIterator(ColumnFilter columnFilter,
Partition partition)
Given a partition, returns a row iterator for the rows of this partition that are selected by this filter.
|
UnfilteredRowIterator |
ClusteringIndexNamesFilter.getUnfilteredRowIterator(ColumnFilter columnFilter,
Partition partition) |
UnfilteredRowIterator |
ClusteringIndexSliceFilter.getUnfilteredRowIterator(ColumnFilter columnFilter,
Partition partition) |
Modifier and Type | Method and Description |
---|---|
UnfilteredRowIterator |
DataLimits.Counter.applyTo(UnfilteredRowIterator partition) |
UnfilteredRowIterator |
DataLimits.filter(UnfilteredRowIterator iter,
int nowInSec,
boolean countPartitionsWithOnlyStaticData) |
UnfilteredRowIterator |
ClusteringIndexFilter.filterNotIndexed(ColumnFilter columnFilter,
UnfilteredRowIterator iterator)
Returns an iterator that only returns the rows of the provided iterator that this filter selects.
|
UnfilteredRowIterator |
ClusteringIndexNamesFilter.filterNotIndexed(ColumnFilter columnFilter,
UnfilteredRowIterator iterator) |
UnfilteredRowIterator |
ClusteringIndexSliceFilter.filterNotIndexed(ColumnFilter columnFilter,
UnfilteredRowIterator iterator) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractBTreePartition.SlicesIterator |
Modifier and Type | Method and Description |
---|---|
protected UnfilteredRowIterator |
PurgeFunction.applyToPartition(UnfilteredRowIterator partition) |
static UnfilteredRowIterator |
UnfilteredPartitionIterators.getOnlyElement(UnfilteredPartitionIterator iter,
SinglePartitionReadCommand command) |
UnfilteredRowIterator |
SingletonUnfilteredPartitionIterator.next() |
UnfilteredRowIterator |
AbstractBTreePartition.unfilteredIterator() |
UnfilteredRowIterator |
AtomicBTreePartition.unfilteredIterator() |
UnfilteredRowIterator |
Partition.unfilteredIterator()
Returns an UnfilteredRowIterator over all the rows/RT contained by this partition.
|
UnfilteredRowIterator |
AbstractBTreePartition.unfilteredIterator(AbstractBTreePartition.Holder current,
ColumnFilter selection,
Slices slices,
boolean reversed) |
UnfilteredRowIterator |
AtomicBTreePartition.unfilteredIterator(AbstractBTreePartition.Holder current,
ColumnFilter selection,
Slices slices,
boolean reversed) |
UnfilteredRowIterator |
AbstractBTreePartition.unfilteredIterator(ColumnFilter selection,
Slices slices,
boolean reversed) |
UnfilteredRowIterator |
AtomicBTreePartition.unfilteredIterator(ColumnFilter selection,
Slices slices,
boolean reversed) |
UnfilteredRowIterator |
Partition.unfilteredIterator(ColumnFilter columns,
Slices slices,
boolean reversed)
Returns an UnfilteredRowIterator over the rows/RT contained by this partition
selected by the provided slices.
|
Modifier and Type | Method and Description |
---|---|
protected UnfilteredRowIterator |
PurgeFunction.applyToPartition(UnfilteredRowIterator partition) |
protected static AbstractBTreePartition.Holder |
AbstractBTreePartition.build(UnfilteredRowIterator iterator,
int initialRowCapacity) |
protected static AbstractBTreePartition.Holder |
AbstractBTreePartition.build(UnfilteredRowIterator iterator,
int initialRowCapacity,
boolean ordered) |
static ImmutableBTreePartition |
ImmutableBTreePartition.create(UnfilteredRowIterator iterator)
Creates an
ImmutableBTreePartition holding all the data of the provided iterator. |
static ImmutableBTreePartition |
ImmutableBTreePartition.create(UnfilteredRowIterator iterator,
boolean ordered)
Creates an
ImmutableBTreePartition holding all the data of the provided iterator. |
static CachedBTreePartition |
CachedBTreePartition.create(UnfilteredRowIterator iterator,
int nowInSec)
Creates an
ArrayBackedCachedPartition holding all the data of the provided iterator. |
static ImmutableBTreePartition |
ImmutableBTreePartition.create(UnfilteredRowIterator iterator,
int initialRowCapacity)
Creates an
ImmutableBTreePartition holding all the data of the provided iterator. |
static ImmutableBTreePartition |
ImmutableBTreePartition.create(UnfilteredRowIterator iterator,
int initialRowCapacity,
boolean ordered)
Creates an
ImmutableBTreePartition holding all the data of the provided iterator. |
static CachedBTreePartition |
CachedBTreePartition.create(UnfilteredRowIterator iterator,
int initialRowCapacity,
int nowInSec)
Creates an
ArrayBackedCachedPartition holding all the data of the provided iterator. |
static PartitionUpdate |
PartitionUpdate.fromIterator(UnfilteredRowIterator iterator,
ColumnFilter filter)
Turns the given iterator into an update.
|
Modifier and Type | Method and Description |
---|---|
UnfilteredRowIterators.MergeListener |
UnfilteredPartitionIterators.MergeListener.getRowMergeListener(DecoratedKey partitionKey,
java.util.List<UnfilteredRowIterator> versions) |
Constructor and Description |
---|
SingletonUnfilteredPartitionIterator(UnfilteredRowIterator iter) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractUnfilteredRowIterator |
class |
LazilyInitializedUnfilteredRowIterator
Abstract class to create UnfilteredRowIterator that lazily initialize themselves.
|
class |
RowAndDeletionMergeIterator
An iterator that merges a source of rows with the range tombstone and partition level deletion of a give partition.
|
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).
|
class |
WrappingUnfilteredRowIterator
Abstract class to make writing unfiltered iterators that wrap another iterator
easier.
|
Modifier and Type | Field and Description |
---|---|
protected UnfilteredRowIterator |
WrappingUnfilteredRowIterator.wrapped |
Modifier and Type | Method and Description |
---|---|
static UnfilteredRowIterator |
UnfilteredRowIterators.concat(UnfilteredRowIterator iter1,
UnfilteredRowIterator iter2)
Returns an iterator that concatenate two atom iterators.
|
static UnfilteredRowIterator |
UnfilteredRowIterators.concat(Unfiltered first,
UnfilteredRowIterator rest)
Returns an iterator that concatenate the specified atom with the iterator.
|
UnfilteredRowIterator |
UnfilteredRowIteratorSerializer.deserialize(DataInputPlus in,
int version,
CFMetaData metadata,
ColumnFilter selection,
SerializationHelper.Flag flag) |
UnfilteredRowIterator |
UnfilteredRowIteratorSerializer.deserialize(DataInputPlus in,
int version,
CFMetaData metadata,
SerializationHelper.Flag flag,
UnfilteredRowIteratorSerializer.Header header) |
protected abstract UnfilteredRowIterator |
LazilyInitializedUnfilteredRowIterator.initializeIterator() |
protected UnfilteredRowIterator |
UnfilteredRowIteratorWithLowerBound.initializeIterator() |
static UnfilteredRowIterator |
UnfilteredRowIterators.loggingIterator(UnfilteredRowIterator iterator,
java.lang.String id,
boolean fullDetails)
Wraps the provided iterator so it logs the returned atoms for debugging purposes.
|
static UnfilteredRowIterator |
UnfilteredRowIterators.merge(java.util.List<UnfilteredRowIterator> iterators,
int nowInSec)
Returns an iterator that is the result of merging other iterators.
|
static UnfilteredRowIterator |
UnfilteredRowIterators.merge(java.util.List<UnfilteredRowIterator> iterators,
int nowInSec,
UnfilteredRowIterators.MergeListener mergeListener)
Returns an iterator that is the result of merging other iterators, and (optionally) using
specific MergeListener.
|
static UnfilteredRowIterator |
UnfilteredRowIterators.noRowsIterator(CFMetaData cfm,
DecoratedKey partitionKey,
Row staticRow,
DeletionTime partitionDeletion,
boolean isReverseOrder)
Returns an empty unfiltered iterator for a given partition.
|
static UnfilteredRowIterator |
UnfilteredRowIterators.withOnlyQueriedData(UnfilteredRowIterator iterator,
ColumnFilter filter)
Filter the provided iterator to exclude cells that have been fetched but are not queried by the user
(see ColumnFilter for detailes).
|
static UnfilteredRowIterator |
UnfilteredRowIterators.withValidation(UnfilteredRowIterator iterator,
java.lang.String filename)
Validate that the data of the provided iterator is valid, that is that the values
it contains are valid for the type they represent, and more generally that the
infos stored are sensible.
|
Modifier and Type | Method and Description |
---|---|
static UnfilteredRowIterator |
UnfilteredRowIterators.concat(UnfilteredRowIterator iter1,
UnfilteredRowIterator iter2)
Returns an iterator that concatenate two atom iterators.
|
static UnfilteredRowIterator |
UnfilteredRowIterators.concat(Unfiltered first,
UnfilteredRowIterator rest)
Returns an iterator that concatenate the specified atom with the iterator.
|
static void |
UnfilteredRowIterators.digest(ReadCommand command,
UnfilteredRowIterator iterator,
java.security.MessageDigest digest,
int version)
Digests the partition represented by the provided iterator.
|
static RowIterator |
UnfilteredRowIterators.filter(UnfilteredRowIterator iter,
int nowInSec)
Returns a iterator that only returns rows with only live content.
|
static UnfilteredRowIterator |
UnfilteredRowIterators.loggingIterator(UnfilteredRowIterator iterator,
java.lang.String id,
boolean fullDetails)
Wraps the provided iterator so it logs the returned atoms for debugging purposes.
|
void |
UnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator,
ColumnFilter selection,
DataOutputPlus out,
int version) |
void |
UnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator,
ColumnFilter selection,
DataOutputPlus out,
int version,
int rowEstimate) |
void |
UnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator,
SerializationHeader header,
ColumnFilter selection,
DataOutputPlus out,
int version,
int rowEstimate) |
long |
UnfilteredRowIteratorSerializer.serializedSize(UnfilteredRowIterator iterator,
ColumnFilter selection,
int version,
int rowEstimate) |
static UnfilteredRowIterator |
UnfilteredRowIterators.withOnlyQueriedData(UnfilteredRowIterator iterator,
ColumnFilter filter)
Filter the provided iterator to exclude cells that have been fetched but are not queried by the user
(see ColumnFilter for detailes).
|
static UnfilteredRowIterator |
UnfilteredRowIterators.withValidation(UnfilteredRowIterator iterator,
java.lang.String filename)
Validate that the data of the provided iterator is valid, that is that the values
it contains are valid for the type they represent, and more generally that the
infos stored are sensible.
|
Modifier and Type | Method and Description |
---|---|
static UnfilteredRowIterator |
UnfilteredRowIterators.merge(java.util.List<UnfilteredRowIterator> iterators,
int nowInSec)
Returns an iterator that is the result of merging other iterators.
|
static UnfilteredRowIterator |
UnfilteredRowIterators.merge(java.util.List<UnfilteredRowIterator> iterators,
int nowInSec,
UnfilteredRowIterators.MergeListener mergeListener)
Returns an iterator that is the result of merging other iterators, and (optionally) using
specific MergeListener.
|
Constructor and Description |
---|
WrappingUnfilteredRowIterator(UnfilteredRowIterator wrapped) |
Modifier and Type | Method and Description |
---|---|
static UnfilteredRowIterator |
Transformation.apply(UnfilteredRowIterator iterator,
Transformation<?> transformation) |
static UnfilteredRowIterator |
MoreRows.extend(UnfilteredRowIterator iterator,
MoreRows<? super UnfilteredRowIterator> more) |
static UnfilteredRowIterator |
MoreRows.extend(UnfilteredRowIterator iterator,
MoreRows<? super UnfilteredRowIterator> more,
PartitionColumns columns) |
Modifier and Type | Method and Description |
---|---|
static UnfilteredRowIterator |
Transformation.apply(UnfilteredRowIterator iterator,
Transformation<?> transformation) |
static UnfilteredRowIterator |
MoreRows.extend(UnfilteredRowIterator iterator,
MoreRows<? super UnfilteredRowIterator> more) |
static UnfilteredRowIterator |
MoreRows.extend(UnfilteredRowIterator iterator,
MoreRows<? super UnfilteredRowIterator> more,
PartitionColumns columns) |
static RowIterator |
FilteredRows.filter(UnfilteredRowIterator iterator,
int nowInSecs)
Filter any RangeTombstoneMarker from the iterator, transforming it into a RowIterator.
|
Modifier and Type | Method and Description |
---|---|
static UnfilteredPartitionIterator |
Transformation.apply(UnfilteredPartitionIterator iterator,
Transformation<? super UnfilteredRowIterator> transformation) |
static UnfilteredRowIterator |
MoreRows.extend(UnfilteredRowIterator iterator,
MoreRows<? super UnfilteredRowIterator> more) |
static UnfilteredRowIterator |
MoreRows.extend(UnfilteredRowIterator iterator,
MoreRows<? super UnfilteredRowIterator> more,
PartitionColumns columns) |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<java.util.Collection<Mutation>> |
TableViews.generateViewUpdates(java.util.Collection<View> views,
UnfilteredRowIterator updates,
UnfilteredRowIterator existings,
int nowInSec,
boolean separateUpdates)
Given some updates on the base table of this object and the existing values for the rows affected by that update, generates the
mutation to be applied to the provided views.
|
Modifier and Type | Method and Description |
---|---|
void |
SecondaryIndexManager.deletePartition(UnfilteredRowIterator partition,
int nowInSec)
Delete all data from all indexes for this partition.
|
Modifier and Type | Method and Description |
---|---|
UnfilteredRowIterator |
QueryController.getPartition(DecoratedKey key,
ReadExecutionController executionController) |
Modifier and Type | Class and Description |
---|---|
class |
SSTableIdentityIterator |
Modifier and Type | Method and Description |
---|---|
boolean |
SSTableMultiWriter.append(UnfilteredRowIterator partition)
Writes a partition in an implementation specific way
|
RowIndexEntry |
SSTableRewriter.append(UnfilteredRowIterator partition) |
boolean |
SSTableTxnWriter.append(UnfilteredRowIterator iterator) |
boolean |
SimpleSSTableMultiWriter.append(UnfilteredRowIterator partition) |
RowIndexEntry |
SSTableRewriter.tryAppend(UnfilteredRowIterator partition) |
Modifier and Type | Method and Description |
---|---|
abstract UnfilteredRowIterator |
SSTableReader.iterator(DecoratedKey key,
Slices slices,
ColumnFilter selectedColumns,
boolean reversed,
SSTableReadsListener listener) |
abstract UnfilteredRowIterator |
SSTableReader.iterator(FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry,
Slices slices,
ColumnFilter selectedColumns,
boolean reversed) |
abstract UnfilteredRowIterator |
SSTableReader.simpleIterator(FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry,
boolean tombstoneOnly) |
Modifier and Type | Method and Description |
---|---|
boolean |
RangeAwareSSTableWriter.append(UnfilteredRowIterator partition) |
abstract RowIndexEntry |
SSTableWriter.append(UnfilteredRowIterator iterator)
Appends partition data to this writer.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Iterator<UnfilteredRowIterator> |
BigTableScanner.iterator |
Modifier and Type | Method and Description |
---|---|
protected UnfilteredRowIterator |
BigTableScanner.KeyScanningIterator.computeNext() |
UnfilteredRowIterator |
BigTableReader.iterator(DecoratedKey key,
Slices slices,
ColumnFilter selectedColumns,
boolean reversed,
SSTableReadsListener listener) |
UnfilteredRowIterator |
BigTableReader.iterator(FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry,
Slices slices,
ColumnFilter selectedColumns,
boolean reversed) |
UnfilteredRowIterator |
BigTableScanner.next() |
UnfilteredRowIterator |
BigTableScanner.EmptySSTableScanner.next() |
UnfilteredRowIterator |
BigTableReader.simpleIterator(FileDataInput dfile,
DecoratedKey key,
RowIndexEntry position,
boolean tombstoneOnly) |
Modifier and Type | Method and Description |
---|---|
RowIndexEntry |
BigTableWriter.append(UnfilteredRowIterator iterator)
Appends partition data to this writer.
|
Modifier and Type | Method and Description |
---|---|
void |
Validator.add(UnfilteredRowIterator partition)
Called (in order) for every row present in the CF.
|
Modifier and Type | Class and Description |
---|---|
static class |
StreamReader.StreamDeserializer |
Modifier and Type | Method and Description |
---|---|
static void |
JsonTransformer.toJson(ISSTableScanner currentScanner,
java.util.stream.Stream<UnfilteredRowIterator> partitions,
boolean rawTime,
CFMetaData metadata,
java.io.OutputStream out) |
Modifier and Type | Method and Description |
---|---|
abstract UnfilteredRowIterator |
EnsureOnHeap.applyToPartition(UnfilteredRowIterator partition) |
Modifier and Type | Method and Description |
---|---|
abstract UnfilteredRowIterator |
EnsureOnHeap.applyToPartition(UnfilteredRowIterator partition) |
Copyright © 2018 The Apache Software Foundation