Uses of Interface
org.apache.cassandra.db.rows.UnfilteredRowIterator
Packages that use UnfilteredRowIterator
Package
Description
File transfer
-
Uses of UnfilteredRowIterator in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return UnfilteredRowIteratorModifier and TypeMethodDescriptionStorageHook.makeRowIterator(ColumnFamilyStore cfs, SSTableReader sstable, DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) SinglePartitionReadCommand.queryMemtableAndDisk(ColumnFamilyStore cfs, ColumnFamilyStore.ViewFragment view, Function<CellSourceIdentifier, Transformation<BaseRowIterator<?>>> rowTransformer, ReadExecutionController executionController) SinglePartitionReadCommand.queryMemtableAndDisk(ColumnFamilyStore cfs, ReadExecutionController executionController) Queries both memtable and sstables to fetch the result of this query.static UnfilteredRowIteratorEmptyIterators.unfilteredRow(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder) static UnfilteredRowIteratorEmptyIterators.unfilteredRow(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder, Row staticRow, DeletionTime partitionDeletion) Methods in org.apache.cassandra.db that return types with arguments of type UnfilteredRowIteratorModifier and TypeMethodDescriptionAbstractCompactionController.shadowSources(DecoratedKey key, boolean tombstoneOnly) -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction that return UnfilteredRowIteratorMethods in org.apache.cassandra.db.compaction that return types with arguments of type UnfilteredRowIteratorModifier and TypeMethodDescriptionCompactionController.shadowSources(DecoratedKey key, boolean tombstoneOnly) -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.compaction.unified
Methods in org.apache.cassandra.db.compaction.unified with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionvoidShardedMultiWriter.append(UnfilteredRowIterator partition) -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.compaction.writers
Methods in org.apache.cassandra.db.compaction.writers with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionfinal booleanCompactionAwareWriter.append(UnfilteredRowIterator partition) Writes a partition in an implementation specific wayprotected booleanCompactionAwareWriter.realAppend(UnfilteredRowIterator partition) booleanMajorLeveledCompactionWriter.realAppend(UnfilteredRowIterator partition) -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter that return UnfilteredRowIteratorModifier and TypeMethodDescriptionDataLimits.Counter.applyTo(UnfilteredRowIterator partition) DataLimits.filter(UnfilteredRowIterator iter, long nowInSec, boolean countPartitionsWithOnlyStaticData) ClusteringIndexFilter.filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator) Returns an iterator that only returns the rows of the provided iterator that this filter selects.ClusteringIndexNamesFilter.filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator) ClusteringIndexSliceFilter.filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator) 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.ClusteringIndexNamesFilter.getUnfilteredRowIterator(ColumnFilter columnFilter, Partition partition) ClusteringIndexSliceFilter.getUnfilteredRowIterator(ColumnFilter columnFilter, Partition partition) Methods in org.apache.cassandra.db.filter with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionDataLimits.Counter.applyTo(UnfilteredRowIterator partition) DataLimits.filter(UnfilteredRowIterator iter, long nowInSec, boolean countPartitionsWithOnlyStaticData) ClusteringIndexFilter.filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator) Returns an iterator that only returns the rows of the provided iterator that this filter selects.ClusteringIndexNamesFilter.filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator) ClusteringIndexSliceFilter.filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator) -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable that return UnfilteredRowIteratorModifier and TypeMethodDescriptionShardedSkipListMemtable.MemtableUnfilteredPartitionIterator.next()ShardedSkipListMemtable.rowIterator(DecoratedKey key) ShardedSkipListMemtable.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) SkipListMemtable.rowIterator(DecoratedKey key) SkipListMemtable.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) TrieMemtable.rowIterator(DecoratedKey key) TrieMemtable.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions that return UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected UnfilteredRowIteratorPurgeFunction.applyToPartition(UnfilteredRowIterator partition) static UnfilteredRowIteratorUnfilteredPartitionIterators.getOnlyElement(UnfilteredPartitionIterator iter, SinglePartitionReadCommand command) SingletonUnfilteredPartitionIterator.next()AbstractBTreePartition.unfilteredIterator()AbstractBTreePartition.unfilteredIterator(ColumnFilter selection, NavigableSet<Clustering<?>> clusteringsInQueryOrder, boolean reversed) AbstractBTreePartition.unfilteredIterator(ColumnFilter selection, Slices slices, boolean reversed) AbstractBTreePartition.unfilteredIterator(BTreePartitionData current, ColumnFilter selection, Slices slices, boolean reversed) AtomicBTreePartition.unfilteredIterator(BTreePartitionData current, ColumnFilter selection, Slices slices, boolean reversed) Partition.unfilteredIterator()Returns an UnfilteredRowIterator over all the rows/RT contained by this partition.Partition.unfilteredIterator(ColumnFilter columns, NavigableSet<Clustering<?>> clusteringsInQueryOrder, boolean reversed) Returns an UnfilteredRowIterator over the rows/RT contained by this partition selected by the provided clusterings.Partition.unfilteredIterator(ColumnFilter columns, Slices slices, boolean reversed) Returns an UnfilteredRowIterator over the rows/RT contained by this partition selected by the provided slices.Methods in org.apache.cassandra.db.partitions with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected UnfilteredRowIteratorPurgeFunction.applyToPartition(UnfilteredRowIterator partition) protected static BTreePartitionDataAbstractBTreePartition.build(UnfilteredRowIterator iterator, int initialRowCapacity) protected static BTreePartitionDataAbstractBTreePartition.build(UnfilteredRowIterator iterator, int initialRowCapacity, boolean ordered) static CachedBTreePartitionCachedBTreePartition.create(UnfilteredRowIterator iterator, int initialRowCapacity, long nowInSec) Creates anArrayBackedCachedPartitionholding all the data of the provided iterator.static CachedBTreePartitionCachedBTreePartition.create(UnfilteredRowIterator iterator, long nowInSec) Creates anArrayBackedCachedPartitionholding all the data of the provided iterator.static ImmutableBTreePartitionImmutableBTreePartition.create(UnfilteredRowIterator iterator) Creates anImmutableBTreePartitionholding all the data of the provided iterator.static ImmutableBTreePartitionImmutableBTreePartition.create(UnfilteredRowIterator iterator, boolean ordered) Creates anImmutableBTreePartitionholding all the data of the provided iterator.static ImmutableBTreePartitionImmutableBTreePartition.create(UnfilteredRowIterator iterator, int initialRowCapacity) Creates anImmutableBTreePartitionholding all the data of the provided iterator.static ImmutableBTreePartitionImmutableBTreePartition.create(UnfilteredRowIterator iterator, int initialRowCapacity, boolean ordered) Creates anImmutableBTreePartitionholding all the data of the provided iterator.static PartitionUpdatePartitionUpdate.fromIterator(UnfilteredRowIterator iterator, ColumnFilter filter) Turns the given iterator into an update.Method parameters in org.apache.cassandra.db.partitions with type arguments of type UnfilteredRowIteratorModifier and TypeMethodDescriptionUnfilteredPartitionIterators.MergeListener.getRowMergeListener(DecoratedKey partitionKey, List<UnfilteredRowIterator> versions) Constructors in org.apache.cassandra.db.partitions with parameters of type UnfilteredRowIterator -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.repair
Methods in org.apache.cassandra.db.repair that return UnfilteredRowIterator -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.rows
Subinterfaces of UnfilteredRowIterator in org.apache.cassandra.db.rowsModifier and TypeInterfaceDescriptioninterfaceAbstract class to make writing unfiltered iterators that wrap another iterator easier.Classes in org.apache.cassandra.db.rows that implement UnfilteredRowIteratorModifier and TypeClassDescriptionclassclassAbstract class to create UnfilteredRowIterator that lazily initializes itself.classAn iterator that merges a source of rows with the range tombstone and partition level deletion of a give partition.classAn 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).Methods in org.apache.cassandra.db.rows that return UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected UnfilteredRowIteratorThrottledUnfilteredIterator.computeNext()static UnfilteredRowIteratorUnfilteredRowIterators.concat(Unfiltered first, UnfilteredRowIterator wrapped) Returns an iterator that concatenate the specified atom with the iterator.static UnfilteredRowIteratorUnfilteredRowIterators.concat(UnfilteredRowIterator iter1, UnfilteredRowIterator iter2) Returns an iterator that concatenate two atom iterators.UnfilteredRowIteratorSerializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag) UnfilteredRowIteratorSerializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, DeserializationHelper.Flag flag, UnfilteredRowIteratorSerializer.Header header) protected abstract UnfilteredRowIteratorLazilyInitializedUnfilteredRowIterator.initializeIterator()protected UnfilteredRowIteratorUnfilteredRowIteratorWithLowerBound.initializeIterator()static UnfilteredRowIteratorUnfilteredRowIterators.loggingIterator(UnfilteredRowIterator iterator, String id, boolean fullDetails) Wraps the provided iterator so it logs the returned atoms for debugging purposes.static UnfilteredRowIteratorUnfilteredRowIterators.merge(List<UnfilteredRowIterator> iterators) Returns an iterator that is the result of merging other iterators.static UnfilteredRowIteratorUnfilteredRowIterators.merge(List<UnfilteredRowIterator> iterators, UnfilteredRowIterators.MergeListener mergeListener) Returns an iterator that is the result of merging other iterators, and (optionally) using specific MergeListener.static UnfilteredRowIteratorUnfilteredRowIterators.noRowsIterator(TableMetadata metadata, DecoratedKey partitionKey, Row staticRow, DeletionTime partitionDeletion, boolean isReverseOrder) Returns an empty unfiltered iterator for a given partition.default UnfilteredRowIteratorUnfilteredSource.rowIterator(DecoratedKey key) UnfilteredSource.rowIterator(DecoratedKey key, Slices slices, ColumnFilter columnFilter, boolean reversed, SSTableReadsListener listener) Returns a row iterator for the given partition, applying the specified row and column filters.static UnfilteredRowIteratorUnfilteredRowIterators.singleton(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats encodingStats) static UnfilteredRowIteratorUnfilteredRowIterators.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 UnfilteredRowIteratorUnfilteredRowIterators.withValidation(UnfilteredRowIterator iterator, 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.WrappingUnfilteredRowIterator.wrapped()Methods in org.apache.cassandra.db.rows that return types with arguments of type UnfilteredRowIteratorModifier and TypeMethodDescriptionThrottledUnfilteredIterator.throttle(UnfilteredPartitionIterator partitionIterator, int maxBatchSize) Splits aUnfilteredPartitionIteratorinUnfilteredRowIteratorbatches with size no higher than maxBatchSizeMethods in org.apache.cassandra.db.rows with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionstatic UnfilteredRowIteratorUnfilteredRowIterators.concat(Unfiltered first, UnfilteredRowIterator wrapped) Returns an iterator that concatenate the specified atom with the iterator.static UnfilteredRowIteratorUnfilteredRowIterators.concat(UnfilteredRowIterator iter1, UnfilteredRowIterator iter2) Returns an iterator that concatenate two atom iterators.static voidUnfilteredRowIterators.digest(UnfilteredRowIterator iterator, Digest digest, int version) Digests the partition represented by the provided iterator.static RowIteratorUnfilteredRowIterators.filter(UnfilteredRowIterator iter, long nowInSec) Returns a iterator that only returns rows with only live content.static UnfilteredRowIteratorUnfilteredRowIterators.loggingIterator(UnfilteredRowIterator iterator, String id, boolean fullDetails) Wraps the provided iterator so it logs the returned atoms for debugging purposes.voidUnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version) voidUnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version, int rowEstimate) longUnfilteredRowIteratorSerializer.serializedSize(UnfilteredRowIterator iterator, ColumnFilter selection, int version, int rowEstimate) static UnfilteredRowIteratorUnfilteredRowIterators.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 UnfilteredRowIteratorUnfilteredRowIterators.withValidation(UnfilteredRowIterator iterator, 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.Method parameters in org.apache.cassandra.db.rows with type arguments of type UnfilteredRowIteratorModifier and TypeMethodDescriptionstatic UnfilteredRowIteratorUnfilteredRowIterators.merge(List<UnfilteredRowIterator> iterators) Returns an iterator that is the result of merging other iterators.static UnfilteredRowIteratorUnfilteredRowIterators.merge(List<UnfilteredRowIterator> iterators, UnfilteredRowIterators.MergeListener mergeListener) Returns an iterator that is the result of merging other iterators, and (optionally) using specific MergeListener. -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.streaming
Classes in org.apache.cassandra.db.streaming that implement UnfilteredRowIteratorMethods in org.apache.cassandra.db.streaming that return UnfilteredRowIterator -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform that return UnfilteredRowIteratorModifier and TypeMethodDescriptionstatic UnfilteredRowIteratorTransformation.apply(UnfilteredRowIterator iterator, Transformation<?> transformation) RTBoundCloser.applyToPartition(UnfilteredRowIterator partition) RTBoundValidator.applyToPartition(UnfilteredRowIterator partition) static UnfilteredRowIteratorRTBoundCloser.close(UnfilteredRowIterator partition) static UnfilteredRowIteratorMoreRows.extend(UnfilteredRowIterator iterator, MoreRows<? super UnfilteredRowIterator> more) static UnfilteredRowIteratorMoreRows.extend(UnfilteredRowIterator iterator, MoreRows<? super UnfilteredRowIterator> more, RegularAndStaticColumns columns) static UnfilteredRowIteratorRTBoundValidator.validate(UnfilteredRowIterator partition, RTBoundValidator.Stage stage, boolean enforceIsClosed) Methods in org.apache.cassandra.db.transform with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionstatic UnfilteredRowIteratorTransformation.apply(UnfilteredRowIterator iterator, Transformation<?> transformation) RTBoundCloser.applyToPartition(UnfilteredRowIterator partition) RTBoundValidator.applyToPartition(UnfilteredRowIterator partition) static UnfilteredRowIteratorRTBoundCloser.close(UnfilteredRowIterator partition) static UnfilteredRowIteratorMoreRows.extend(UnfilteredRowIterator iterator, MoreRows<? super UnfilteredRowIterator> more) static UnfilteredRowIteratorMoreRows.extend(UnfilteredRowIterator iterator, MoreRows<? super UnfilteredRowIterator> more, RegularAndStaticColumns columns) static RowIteratorFilteredRows.filter(UnfilteredRowIterator iterator, long nowInSecs) Filter any RangeTombstoneMarker from the iterator, transforming it into a RowIterator.static UnfilteredRowIteratorRTBoundValidator.validate(UnfilteredRowIterator partition, RTBoundValidator.Stage stage, boolean enforceIsClosed) Method parameters in org.apache.cassandra.db.transform with type arguments of type UnfilteredRowIteratorModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorTransformation.apply(UnfilteredPartitionIterator iterator, Transformation<? super UnfilteredRowIterator> transformation) static UnfilteredRowIteratorMoreRows.extend(UnfilteredRowIterator iterator, MoreRows<? super UnfilteredRowIterator> more) static UnfilteredRowIteratorMoreRows.extend(UnfilteredRowIterator iterator, MoreRows<? super UnfilteredRowIterator> more, RegularAndStaticColumns columns) -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.view
Methods in org.apache.cassandra.db.view with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionTableViews.generateViewUpdates(Collection<View> views, UnfilteredRowIterator updates, UnfilteredRowIterator existings, long 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. -
Uses of UnfilteredRowIterator in org.apache.cassandra.db.virtual
Methods in org.apache.cassandra.db.virtual that return UnfilteredRowIteratorModifier and TypeMethodDescriptionAbstractVirtualTable.Partition.toRowIterator(TableMetadata metadata, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter, long now) -
Uses of UnfilteredRowIterator in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionvoidSecondaryIndexManager.deletePartition(UnfilteredRowIterator partition, long nowInSec) Delete all data from all indexes for this partition. -
Uses of UnfilteredRowIterator in org.apache.cassandra.index.sai.plan
Methods in org.apache.cassandra.index.sai.plan that return UnfilteredRowIteratorModifier and TypeMethodDescriptionStorageAttachedIndexSearcher.ScoreOrderedResultRetriever.computeNext()QueryController.queryStorage(List<PrimaryKey> keys, ReadExecutionController executionController) QueryController.queryStorage(PrimaryKey key, ColumnFamilyStore.ViewFragment view, ReadExecutionController executionController) Get an iterator over the row(s) for this primary key.StorageAttachedIndexSearcher.ScoreOrderedResultRetriever.readAndValidatePartition(PrimaryKey pk, List<PrimaryKeyWithScore> sourceKeys) Reads and validates a partition for a given primary key against its sources. -
Uses of UnfilteredRowIterator in org.apache.cassandra.index.sai.utils
Methods in org.apache.cassandra.index.sai.utils that return UnfilteredRowIterator -
Uses of UnfilteredRowIterator in org.apache.cassandra.index.sasi.plan
Methods in org.apache.cassandra.index.sasi.plan that return UnfilteredRowIteratorModifier and TypeMethodDescriptionQueryController.getPartition(DecoratedKey key, ReadExecutionController executionController) -
Uses of UnfilteredRowIterator in org.apache.cassandra.io.sstable
Classes in org.apache.cassandra.io.sstable that implement UnfilteredRowIteratorModifier and TypeClassDescriptionclassAbstractSSTableIterator<RIE extends AbstractRowIndexEntry>classMethods in org.apache.cassandra.io.sstable that return UnfilteredRowIteratorMethods in org.apache.cassandra.io.sstable with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionvoidRangeAwareSSTableWriter.append(UnfilteredRowIterator partition) voidSimpleSSTableMultiWriter.append(UnfilteredRowIterator partition) voidSSTableMultiWriter.append(UnfilteredRowIterator partition) Writes a partition in an implementation specific waySSTableRewriter.append(UnfilteredRowIterator partition) voidSSTableTxnWriter.append(UnfilteredRowIterator iterator) voidSSTableZeroCopyWriter.append(UnfilteredRowIterator partition) SSTableRewriter.tryAppend(UnfilteredRowIterator partition) -
Uses of UnfilteredRowIterator in org.apache.cassandra.io.sstable.format
Methods in org.apache.cassandra.io.sstable.format that return UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected UnfilteredRowIteratorSSTableScanner.BaseKeyScanningIterator.computeNext()protected abstract UnfilteredRowIteratorSSTableScanner.BaseKeyScanningIterator.getRowIterator(E indexEntry, DecoratedKey key) SSTableScanner.next()SSTableSimpleScanner.next()SSTableReader.simpleIterator(FileDataInput file, DecoratedKey key, long dataPosition, boolean tombstoneOnly) protected abstract UnfilteredRowIteratorSortedTableScrubber.withValidation(UnfilteredRowIterator iter, String filename) Methods in org.apache.cassandra.io.sstable.format with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionfinal AbstractRowIndexEntrySortedTableWriter.append(UnfilteredRowIterator partition) Appends partition data to this writer.abstract AbstractRowIndexEntrySSTableWriter.append(UnfilteredRowIterator iterator) Appends partition data to this writer.protected abstract voidSortedTableVerifier.verifyPartition(DecoratedKey key, UnfilteredRowIterator iterator) protected abstract UnfilteredRowIteratorSortedTableScrubber.withValidation(UnfilteredRowIterator iter, String filename) -
Uses of UnfilteredRowIterator in org.apache.cassandra.io.sstable.format.big
Classes in org.apache.cassandra.io.sstable.format.big that implement UnfilteredRowIteratorModifier and TypeClassDescriptionclassA Cell Iterator over SSTableclassA Cell Iterator in reversed clustering order over SSTableMethods in org.apache.cassandra.io.sstable.format.big that return UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected UnfilteredRowIteratorBigTableScanner.BigScanningIterator.getRowIterator(RowIndexEntry rowIndexEntry, DecoratedKey key) BigTableReader.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) BigTableReader.rowIterator(FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed) protected UnfilteredRowIteratorBigTableScrubber.withValidation(UnfilteredRowIterator iter, String filename) Methods in org.apache.cassandra.io.sstable.format.big with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected voidBigTableVerifier.verifyPartition(DecoratedKey key, UnfilteredRowIterator iterator) protected UnfilteredRowIteratorBigTableScrubber.withValidation(UnfilteredRowIterator iter, String filename) -
Uses of UnfilteredRowIterator in org.apache.cassandra.io.sstable.format.bti
Methods in org.apache.cassandra.io.sstable.format.bti that return UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected UnfilteredRowIteratorBtiTableScanner.BtiScanningIterator.getRowIterator(org.apache.cassandra.io.sstable.format.bti.TrieIndexEntry indexEntry, DecoratedKey key) BtiTableReader.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) BtiTableReader.rowIterator(FileDataInput dataFileInput, DecoratedKey key, org.apache.cassandra.io.sstable.format.bti.TrieIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed) protected UnfilteredRowIteratorBtiTableScrubber.withValidation(UnfilteredRowIterator iter, String filename) Methods in org.apache.cassandra.io.sstable.format.bti with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected voidBtiTableVerifier.verifyPartition(DecoratedKey key, UnfilteredRowIterator iterator) protected UnfilteredRowIteratorBtiTableScrubber.withValidation(UnfilteredRowIterator iter, String filename) -
Uses of UnfilteredRowIterator in org.apache.cassandra.metrics
Methods in org.apache.cassandra.metrics that return UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected UnfilteredRowIteratorTopPartitionTracker.TombstoneCounter.applyToPartition(UnfilteredRowIterator partition) Methods in org.apache.cassandra.metrics with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionprotected UnfilteredRowIteratorTopPartitionTracker.TombstoneCounter.applyToPartition(UnfilteredRowIterator partition) -
Uses of UnfilteredRowIterator in org.apache.cassandra.repair
Methods in org.apache.cassandra.repair with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionvoidValidator.add(UnfilteredRowIterator partition) Called (in order) for every row present in the CF. -
Uses of UnfilteredRowIterator in org.apache.cassandra.service.reads
Methods in org.apache.cassandra.service.reads that return UnfilteredRowIteratorModifier and TypeMethodDescriptionShortReadPartitionsProtection.applyToPartition(UnfilteredRowIterator partition) Methods in org.apache.cassandra.service.reads with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionShortReadPartitionsProtection.applyToPartition(UnfilteredRowIterator partition) -
Uses of UnfilteredRowIterator in org.apache.cassandra.service.reads.repair
Method parameters in org.apache.cassandra.service.reads.repair with type arguments of type UnfilteredRowIteratorModifier and TypeMethodDescriptionstatic RegularAndStaticColumnsPartitionIteratorMergeListener.columns(List<UnfilteredRowIterator> versions) PartitionIteratorMergeListener.getRowMergeListener(DecoratedKey partitionKey, List<UnfilteredRowIterator> versions) protected booleanPartitionIteratorMergeListener.isReversed(List<UnfilteredRowIterator> versions) -
Uses of UnfilteredRowIterator in org.apache.cassandra.tools
Method parameters in org.apache.cassandra.tools with type arguments of type UnfilteredRowIteratorModifier and TypeMethodDescriptionstatic voidJsonTransformer.toJson(ISSTableScanner currentScanner, Stream<UnfilteredRowIterator> partitions, boolean rawTime, TableMetadata metadata, OutputStream out) static voidJsonTransformer.toJsonLines(ISSTableScanner currentScanner, Stream<UnfilteredRowIterator> partitions, boolean rawTime, TableMetadata metadata, OutputStream out) -
Uses of UnfilteredRowIterator in org.apache.cassandra.utils.memory
Methods in org.apache.cassandra.utils.memory that return UnfilteredRowIteratorModifier and TypeMethodDescriptionabstract UnfilteredRowIteratorEnsureOnHeap.applyToPartition(UnfilteredRowIterator partition) Methods in org.apache.cassandra.utils.memory with parameters of type UnfilteredRowIteratorModifier and TypeMethodDescriptionabstract UnfilteredRowIteratorEnsureOnHeap.applyToPartition(UnfilteredRowIterator partition)