Uses of Class
org.apache.cassandra.io.sstable.format.SSTableReader

Packages that use SSTableReader

Package	Description
org.apache.cassandra.db
org.apache.cassandra.db.commitlog
org.apache.cassandra.db.compaction
org.apache.cassandra.db.compaction.unified
org.apache.cassandra.db.compaction.writers
org.apache.cassandra.db.lifecycle
org.apache.cassandra.db.repair
org.apache.cassandra.db.rows
org.apache.cassandra.db.streaming	File transfer
org.apache.cassandra.index
org.apache.cassandra.index.internal
org.apache.cassandra.index.sai
org.apache.cassandra.index.sai.disk
org.apache.cassandra.index.sai.disk.format
org.apache.cassandra.index.sai.disk.v1
org.apache.cassandra.index.sai.view
org.apache.cassandra.index.sasi
org.apache.cassandra.index.sasi.conf
org.apache.cassandra.io.sstable
org.apache.cassandra.io.sstable.filter
org.apache.cassandra.io.sstable.format
org.apache.cassandra.io.sstable.format.big
org.apache.cassandra.io.sstable.format.bti
org.apache.cassandra.io.sstable.indexsummary
org.apache.cassandra.io.sstable.keycache
org.apache.cassandra.io.sstable.metadata
org.apache.cassandra.notifications
org.apache.cassandra.repair.consistent.admin
org.apache.cassandra.streaming
org.apache.cassandra.tools

Uses of SSTableReader in org.apache.cassandra.db

Fields in org.apache.cassandra.db with type parameters of type SSTableReader

Modifier and Type	Field	Description
final Refs<SSTableReader>	ColumnFamilyStore.RefViewFragment.refs
final List<SSTableReader>	ColumnFamilyStore.ViewFragment.sstables

Methods in org.apache.cassandra.db that return SSTableReader

Modifier and Type	Method	Description
SSTableReader	ColumnFamilyStore.getMaxSizeFile(Iterable<SSTableReader> sstables)

Methods in org.apache.cassandra.db that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
List<SSTableReader>	Keyspace.getAllSSTables(SSTableSet sstableSet)
Refs<SSTableReader>	ColumnFamilyStore.getAndReferenceOverlappingLiveSSTables(Iterable<SSTableReader> sstables)	like getOverlappingSSTables, but acquires references before returning
Set<SSTableReader>	ColumnFamilyStore.getLiveSSTables()
Collection<SSTableReader>	ColumnFamilyStore.getOverlappingLiveSSTables(Iterable<SSTableReader> sstables)
Refs<SSTableReader>	ColumnFamilyStore.getSnapshotSSTableReaders(String tag)
Iterable<SSTableReader>	ColumnFamilyStore.getSSTables(SSTableSet sstableSet)
Iterable<SSTableReader>	ColumnFamilyStore.getUncompactingSSTables()

Methods in org.apache.cassandra.db with parameters of type SSTableReader

Modifier and Type	Method	Description
void	ColumnFamilyStore.addSSTable(SSTableReader sstable)
Directories.DataDirectory	DiskBoundaries.getCorrectDiskForSSTable(SSTableReader sstable)
int	DiskBoundaries.getDiskIndex(SSTableReader sstable)
static void	UnfilteredValidation.handleInvalid(TableMetadata metadata, DecoratedKey key, SSTableReader sstable, String invalidContent)
protected boolean	ReadCommand.hasPartitionLevelDeletions(SSTableReader sstable)
protected boolean	ReadCommand.hasRequiredStatics(SSTableReader sstable)
protected boolean	PartitionRangeReadCommand.intersects(SSTableReader sstable)
protected abstract boolean	ReadCommand.intersects(SSTableReader sstable)
protected boolean	SinglePartitionReadCommand.intersects(SSTableReader sstable)
boolean	DiskBoundaries.isInCorrectLocation(SSTableReader sstable, Directories.DataDirectory currentLocation)
UnfilteredRowIterator	StorageHook.makeRowIterator(ColumnFamilyStore cfs, SSTableReader sstable, DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener)
UnfilteredRowIteratorWithLowerBound	StorageHook.makeRowIteratorWithLowerBound(ColumnFamilyStore cfs, SSTableReader sstable, DecoratedKey partitionKey, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener)
static void	UnfilteredValidation.maybeValidateUnfiltered(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey key, SSTableReader sstable)

Method parameters in org.apache.cassandra.db with type arguments of type SSTableReader

Modifier and Type	Method	Description
void	ColumnFamilyStore.addSSTables(Collection<SSTableReader> sstables)
protected TableSnapshot	ColumnFamilyStore.createSnapshot(String tag, boolean ephemeral, DurationSpec.IntSecondsBound ttl, Set<SSTableReader> sstables, Instant creationTime)
Refs<SSTableReader>	ColumnFamilyStore.getAndReferenceOverlappingLiveSSTables(Iterable<SSTableReader> sstables)	like getOverlappingSSTables, but acquires references before returning
List<File>	ColumnFamilyStore.getDirectoriesForFiles(Set<SSTableReader> sstables)	Grabs the global first/last tokens among sstables and returns the range of data directories that start/end with those tokens.
long	ColumnFamilyStore.getExpectedCompactedFileSize(Iterable<SSTableReader> sstables, OperationType operation)	Calculate expected file size of SSTable after compaction.
SSTableReader	ColumnFamilyStore.getMaxSizeFile(Iterable<SSTableReader> sstables)
Collection<SSTableReader>	ColumnFamilyStore.getOverlappingLiveSSTables(Iterable<SSTableReader> sstables)
static SerializationHeader	SerializationHeader.make(TableMetadata metadata, Collection<SSTableReader> sstables)
void	ColumnFamilyStore.markObsolete(Collection<SSTableReader> sstables, OperationType compactionType)
<V> V	ColumnFamilyStore.runWithCompactionsDisabled(Callable<V> callable, com.google.common.base.Predicate<SSTableReader> sstablesPredicate, OperationType operationType, boolean interruptValidation, boolean interruptViews, boolean interruptIndexes)	Runs callable with compactions paused and compactions including sstables matching sstablePredicate stopped
ColumnFamilyStore.ViewFragment	ColumnFamilyStore.select(com.google.common.base.Function<View,Iterable<SSTableReader>> filter)
ColumnFamilyStore.RefViewFragment	ColumnFamilyStore.selectAndReference(com.google.common.base.Function<View,Iterable<SSTableReader>> filter)
TableSnapshot	ColumnFamilyStore.snapshot(String snapshotName, com.google.common.base.Predicate<SSTableReader> predicate, boolean ephemeral, boolean skipMemtable)
TableSnapshot	ColumnFamilyStore.snapshot(String snapshotName, com.google.common.base.Predicate<SSTableReader> predicate, boolean ephemeral, boolean skipMemtable, DurationSpec.IntSecondsBound ttl, com.google.common.util.concurrent.RateLimiter rateLimiter, Instant creationTime)
TableSnapshot	ColumnFamilyStore.snapshotWithoutMemtable(String snapshotName, com.google.common.base.Predicate<SSTableReader> predicate, boolean ephemeral, DurationSpec.IntSecondsBound ttl, com.google.common.util.concurrent.RateLimiter rateLimiter, Instant creationTime)
<T> List<T>	ColumnFamilyStore.withSSTablesForKey(String key, boolean hexFormat, com.google.common.base.Function<SSTableReader,T> mapper)
void	ColumnFamilyStore.writeAndAddMemtableRanges(TimeUUID repairSessionID, Supplier<Collection<Range<PartitionPosition>>> rangesSupplier, Refs<SSTableReader> placeIntoRefs)

Constructor parameters in org.apache.cassandra.db with type arguments of type SSTableReader

Modifier	Constructor	Description
	RefViewFragment(List<SSTableReader> sstables, Iterable<Memtable> memtables, Refs<SSTableReader> refs)
	RefViewFragment(List<SSTableReader> sstables, Iterable<Memtable> memtables, Refs<SSTableReader> refs)
	ViewFragment(List<SSTableReader> sstables, Iterable<Memtable> memtables)

Uses of SSTableReader in org.apache.cassandra.db.commitlog

Method parameters in org.apache.cassandra.db.commitlog with type arguments of type SSTableReader

Modifier and Type	Method	Description
static IntervalSet<CommitLogPosition>	CommitLogReplayer.persistedIntervals(Iterable<SSTableReader> onDisk, CommitLogPosition truncatedAt, UUID localhostId)	A set of known safe-to-discard commit log replay positions, based on the range covered by on disk sstables and those prior to the most recent truncation record

Uses of SSTableReader in org.apache.cassandra.db.compaction

Fields in org.apache.cassandra.db.compaction with type parameters of type SSTableReader

Modifier and Type	Field	Description
final Collection<SSTableReader>	LeveledManifest.CompactionCandidate.sstables
protected final Set<SSTableReader>	SizeTieredCompactionStrategy.sstables
protected final Set<SSTableReader>	UnifiedCompactionStrategy.sstables

Methods in org.apache.cassandra.db.compaction that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
static List<Pair<SSTableReader,Long>>	SizeTieredCompactionStrategy.createSSTableAndLengthPairs(Iterable<SSTableReader> sstables)
static List<SSTableReader>	AbstractCompactionStrategy.filterSuspectSSTables(Iterable<SSTableReader> originalCandidates)	Filters SSTables that are to be excluded from the given collection
Set<SSTableReader>	CompactionController.getFullyExpiredSSTables()
static Set<SSTableReader>	CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore, Iterable<SSTableReader> compacting, Iterable<SSTableReader> overlapping, long gcBefore)
static Set<SSTableReader>	CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore, Iterable<SSTableReader> compacting, Iterable<SSTableReader> overlapping, long gcBefore, boolean ignoreOverlaps)	Finds expired sstables works something like this; 1.
Set<SSTableReader>	AbstractStrategyHolder.GroupedSSTableContainer.getGroup(int i)
protected abstract Set<SSTableReader>	AbstractCompactionStrategy.getSSTables()	Returns the sstables managed by this strategy instance
Set<SSTableReader>	CompactionInfo.getSSTables()
protected Set<SSTableReader>	LeveledCompactionStrategy.getSSTables()
Set<SSTableReader>	LeveledManifest.getSSTables()
protected Set<SSTableReader>	SizeTieredCompactionStrategy.getSSTables()
protected Set<SSTableReader>	TimeWindowCompactionStrategy.getSSTables()
protected Set<SSTableReader>	UnifiedCompactionStrategy.getSSTables()
Collection<SSTableReader>	UnifiedCompactionStrategy.Level.getSSTables()
Set<SSTableReader>[]	LeveledManifest.getSStablesPerLevelSnapshot()
Collection<Collection<SSTableReader>>	AbstractCompactionStrategy.groupSSTablesForAntiCompaction(Collection<SSTableReader> sstablesToGroup)	Method for grouping similar SSTables together, This will be used by anti-compaction to determine which SSTables should be anitcompacted as a group.
Collection<Collection<SSTableReader>>	CompactionStrategyManager.groupSSTablesForAntiCompaction(Collection<SSTableReader> sstablesToGroup)
Collection<Collection<SSTableReader>>	LeveledCompactionStrategy.groupSSTablesForAntiCompaction(Collection<SSTableReader> ssTablesToGroup)	Leveled compaction strategy has guarantees on the data contained within each level so we have to make sure we only create groups of SSTables with members from the same level.
Collection<Collection<SSTableReader>>	TimeWindowCompactionStrategy.groupSSTablesForAntiCompaction(Collection<SSTableReader> sstablesToGroup)	TWCS should not group sstables for anticompaction - this can mix new and old data
static List<SSTableReader>	SizeTieredCompactionStrategy.mostInterestingBucket(List<List<SSTableReader>> buckets, int minThreshold, int maxThreshold)

Methods in org.apache.cassandra.db.compaction with parameters of type SSTableReader

Modifier and Type	Method	Description
abstract void	AbstractCompactionStrategy.addSSTable(SSTableReader added)	Adds sstable, note that implementations must handle duplicate notifications here (added already being in the compaction strategy)
abstract void	AbstractStrategyHolder.addSSTable(SSTableReader sstable)
void	CompactionStrategyHolder.addSSTable(SSTableReader sstable)
void	LeveledCompactionStrategy.addSSTable(SSTableReader added)
void	PendingRepairHolder.addSSTable(SSTableReader sstable)
void	SizeTieredCompactionStrategy.addSSTable(SSTableReader added)
void	TimeWindowCompactionStrategy.addSSTable(SSTableReader sstable)
void	UnifiedCompactionStrategy.addSSTable(SSTableReader added)
default int	ShardManager.compareByDensity(SSTableReader a, SSTableReader b)
abstract boolean	AbstractStrategyHolder.containsSSTable(SSTableReader sstable)
boolean	CompactionStrategyHolder.containsSSTable(SSTableReader sstable)
boolean	PendingRepairHolder.containsSSTable(SSTableReader sstable)
static Range<Token>	ShardManager.coveringRange(SSTableReader sstable)
static SSTableWriter	CompactionManager.createWriter(ColumnFamilyStore cfs, File compactionFileLocation, long expectedBloomFilterSize, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SSTableReader sstable, LifecycleTransaction txn)
default double	ShardManager.density(SSTableReader rdr)	Return the density of an SSTable, i.e.
Collection<CompactionInfo>	ActiveCompactions.getCompactionsForSSTable(SSTableReader sstable, OperationType compactionType)	Iterates over the active compactions and tries to find CompactionInfos with the given compactionType for the given sstable Number of entries in compactions should be small (< 10) but avoid calling in any time-sensitive context
AbstractCompactionStrategy	CompactionStrategyManager.getCompactionStrategyFor(SSTableReader sstable)	return the compaction strategy for the given sstable returns differently based on the repaired status and which vnode the compaction strategy belongs to
int	AbstractStrategyHolder.DestinationRouter.getIndexForSSTable(SSTableReader sstable)
abstract AbstractCompactionStrategy	AbstractStrategyHolder.getStrategyFor(SSTableReader sstable)
AbstractCompactionStrategy	CompactionStrategyHolder.getStrategyFor(SSTableReader sstable)
AbstractCompactionStrategy	PendingRepairHolder.getStrategyFor(SSTableReader sstable)
boolean	CompactionStrategyManager.hasPendingRepairSSTable(TimeUUID sessionID, SSTableReader sstable)
boolean	PendingRepairHolder.hasPendingRepairSSTable(TimeUUID sessionID, SSTableReader sstable)
static boolean	UnifiedCompactionStrategy.isSuitableForCompaction(SSTableReader rdr)
boolean	AbstractStrategyHolder.managesSSTable(SSTableReader sstable)
void	AbstractCompactionStrategy.metadataChanged(StatsMetadata oldMetadata, SSTableReader sstable)	Called when the metadata has changed for an sstable - for example if the level changed Not called when repair status changes (which is also metadata), because this results in the sstable getting removed from the compaction strategy instance.
void	LeveledCompactionStrategy.metadataChanged(StatsMetadata oldMetadata, SSTableReader sstable)
static boolean	CompactionManager.needsCleanup(SSTableReader sstable, Collection<Range<Token>> ownedRanges)	Determines if a cleanup would actually remove any data in this SSTable based on a set of owned ranges.
default double	ShardManager.rangeSpanned(SSTableReader rdr)	Return the token space share that the given SSTable spans, excluding any non-locally owned space.
double	ShardManagerTrivial.rangeSpanned(SSTableReader rdr)
int	LeveledManifest.remove(SSTableReader reader)
abstract void	AbstractCompactionStrategy.removeSSTable(SSTableReader sstable)	Removes sstable from the strategy, implementations must be able to handle the sstable having already been removed.
void	LeveledCompactionStrategy.removeSSTable(SSTableReader sstable)
void	SizeTieredCompactionStrategy.removeSSTable(SSTableReader sstable)
void	TimeWindowCompactionStrategy.removeSSTable(SSTableReader sstable)
void	UnifiedCompactionStrategy.removeSSTable(SSTableReader sstable)
com.fasterxml.jackson.databind.JsonNode	CompactionLogger.Strategy.sstable(SSTableReader sstable)
protected boolean	AbstractCompactionStrategy.worthDroppingTombstones(SSTableReader sstable, long gcBefore)	Check if given sstable is worth dropping tombstones at gcBefore.

Method parameters in org.apache.cassandra.db.compaction with type arguments of type SSTableReader

Modifier and Type	Method	Description
void	AbstractCompactionStrategy.addSSTables(Iterable<SSTableReader> added)	Adds sstables, note that implementations must handle duplicate notifications here (added already being in the compaction strategy)
void	LeveledCompactionStrategy.addSSTables(Iterable<SSTableReader> sstables)
void	LeveledManifest.addSSTables(Iterable<SSTableReader> readers)
protected boolean	CompactionTask.buildCompactionCandidatesForAvailableDiskSpace(Set<SSTableReader> fullyExpiredSSTables, TimeUUID taskId)
default double	ShardManager.calculateCombinedDensity(Set<? extends SSTableReader> sstables)	Estimate the density of the sstable that will be the result of compacting the given sources.
double	ShardManagerTrivial.calculateCombinedDensity(Set<? extends SSTableReader> sstables)
void	CompactionLogger.compaction(long startTime, Collection<SSTableReader> input, long endTime, Collection<SSTableReader> output)
static LeveledManifest	LeveledManifest.create(ColumnFamilyStore cfs, int maxSSTableSize, int fanoutSize, Iterable<SSTableReader> sstables, SizeTieredCompactionStrategyOptions options)
static LeveledManifest	LeveledManifest.create(ColumnFamilyStore cfs, int maxSSTableSize, int fanoutSize, List<SSTableReader> sstables)
static List<Pair<SSTableReader,Long>>	SizeTieredCompactionStrategy.createSSTableAndLengthPairs(Iterable<SSTableReader> sstables)
static SSTableWriter	CompactionManager.createWriterForAntiCompaction(ColumnFamilyStore cfs, File compactionFileLocation, int expectedBloomFilterSize, long repairedAt, TimeUUID pendingRepair, boolean isTransient, Collection<SSTableReader> sstables, ILifecycleTransaction txn)
static List<SSTableReader>	AbstractCompactionStrategy.filterSuspectSSTables(Iterable<SSTableReader> originalCandidates)	Filters SSTables that are to be excluded from the given collection
void	CompactionLogger.flush(Collection<SSTableReader> sstables)
void	CompactionManager.forceCompaction(ColumnFamilyStore cfStore, Supplier<Collection<SSTableReader>> sstablesFn, com.google.common.base.Predicate<SSTableReader> sstablesPredicate)
void	CompactionManager.forceCompaction(ColumnFamilyStore cfStore, Supplier<Collection<SSTableReader>> sstablesFn, com.google.common.base.Predicate<SSTableReader> sstablesPredicate)
abstract CompactionAwareWriter	AbstractCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables)
CompactionAwareWriter	CompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction transaction, Set<SSTableReader> nonExpiredSSTables)
CompactionAwareWriter	LeveledCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables)
CompactionAwareWriter	SingleSSTableLCSTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables)
CompactionAwareWriter	SSTableSplitter.SplittingCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables)
protected CompactionController	CompactionTask.getCompactionController(Set<SSTableReader> toCompact)
protected CompactionController	SSTableSplitter.SplittingCompactionTask.getCompactionController(Set<SSTableReader> toCompact)
CompactionController	TimeWindowCompactionTask.getCompactionController(Set<SSTableReader> toCompact)
static int	SizeTieredCompactionStrategy.getEstimatedCompactionsByTasks(ColumnFamilyStore cfs, List<List<SSTableReader>> tasks)
static Set<SSTableReader>	CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore, Iterable<SSTableReader> compacting, Iterable<SSTableReader> overlapping, long gcBefore)
static Set<SSTableReader>	CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore, Iterable<SSTableReader> compacting, Iterable<SSTableReader> overlapping, long gcBefore, boolean ignoreOverlaps)	Finds expired sstables works something like this; 1.
static boolean	CompactionTask.getIsTransient(Set<SSTableReader> sstables)
List<UnifiedCompactionStrategy.Level>	UnifiedCompactionStrategy.getLevels(Collection<SSTableReader> sstables, com.google.common.base.Predicate<SSTableReader> compactionFilter)	Groups the sstables passed in into levels.
List<UnifiedCompactionStrategy.Level>	UnifiedCompactionStrategy.getLevels(Collection<SSTableReader> sstables, com.google.common.base.Predicate<SSTableReader> compactionFilter)	Groups the sstables passed in into levels.
static long	CompactionTask.getMaxDataAge(Collection<SSTableReader> sstables)
static long	CompactionTask.getMinRepairedAt(Set<SSTableReader> actuallyCompact)
int	LeveledManifest.getNextLevel(Collection<SSTableReader> sstables)
static TimeUUID	CompactionTask.getPendingRepair(Set<SSTableReader> sstables)
AbstractCompactionStrategy.ScannerList	AbstractCompactionStrategy.getScanners(Collection<SSTableReader> toCompact)
AbstractCompactionStrategy.ScannerList	AbstractCompactionStrategy.getScanners(Collection<SSTableReader> sstables, Collection<Range<Token>> ranges)	Returns a list of KeyScanners given sstables and a range on which to scan.
AbstractCompactionStrategy.ScannerList	AbstractCompactionStrategy.getScanners(Collection<SSTableReader> sstables, Range<Token> range)
AbstractCompactionStrategy.ScannerList	CompactionStrategyManager.getScanners(Collection<SSTableReader> sstables)
AbstractCompactionStrategy.ScannerList	CompactionStrategyManager.getScanners(Collection<SSTableReader> sstables, Collection<Range<Token>> ranges)
AbstractCompactionStrategy.ScannerList	LeveledCompactionStrategy.getScanners(Collection<SSTableReader> sstables, Collection<Range<Token>> ranges)
abstract AbstractCompactionTask	AbstractCompactionStrategy.getUserDefinedTask(Collection<SSTableReader> sstables, long gcBefore)
AbstractCompactionTask	LeveledCompactionStrategy.getUserDefinedTask(Collection<SSTableReader> sstables, long gcBefore)
AbstractCompactionTask	SizeTieredCompactionStrategy.getUserDefinedTask(Collection<SSTableReader> sstables, long gcBefore)
AbstractCompactionTask	TimeWindowCompactionStrategy.getUserDefinedTask(Collection<SSTableReader> sstables, long gcBefore)
AbstractCompactionTask	UnifiedCompactionStrategy.getUserDefinedTask(Collection<SSTableReader> sstables, long gcBefore)
CompactionTasks	CompactionStrategyManager.getUserDefinedTasks(Collection<SSTableReader> sstables, long gcBefore)	Return a list of compaction tasks corresponding to the sstables requested.
List<AbstractStrategyHolder.GroupedSSTableContainer>	CompactionStrategyManager.groupSSTables(Iterable<SSTableReader> sstables)	Split sstables into a list of grouped sstable containers, the list index an sstable lives in matches the list index of the holder that's responsible for it
Collection<Collection<SSTableReader>>	AbstractCompactionStrategy.groupSSTablesForAntiCompaction(Collection<SSTableReader> sstablesToGroup)	Method for grouping similar SSTables together, This will be used by anti-compaction to determine which SSTables should be anitcompacted as a group.
Collection<Collection<SSTableReader>>	CompactionStrategyManager.groupSSTablesForAntiCompaction(Collection<SSTableReader> sstablesToGroup)
Collection<Collection<SSTableReader>>	LeveledCompactionStrategy.groupSSTablesForAntiCompaction(Collection<SSTableReader> ssTablesToGroup)	Leveled compaction strategy has guarantees on the data contained within each level so we have to make sure we only create groups of SSTables with members from the same level.
Collection<Collection<SSTableReader>>	TimeWindowCompactionStrategy.groupSSTablesForAntiCompaction(Collection<SSTableReader> sstablesToGroup)	TWCS should not group sstables for anticompaction - this can mix new and old data
void	CompactionManager.interruptCompactionFor(Iterable<TableMetadata> columnFamilies, Predicate<SSTableReader> sstablePredicate, boolean interruptValidation)	Try to stop all of the compactions for given ColumnFamilies.
void	CompactionManager.interruptCompactionForCFs(Iterable<ColumnFamilyStore> cfss, Predicate<SSTableReader> sstablePredicate, boolean interruptValidation)
boolean	CompactionManager.isCompacting(Iterable<ColumnFamilyStore> cfses, Predicate<SSTableReader> sstablePredicate)
AbstractCompactionStrategy.ScannerList	CompactionStrategyManager.maybeGetScanners(Collection<SSTableReader> sstables, Collection<Range<Token>> ranges)	Create ISSTableScanners from the given sstables Delegates the call to the compaction strategies to allow LCS to create a scanner
static List<SSTableReader>	SizeTieredCompactionStrategy.mostInterestingBucket(List<List<SSTableReader>> buckets, int minThreshold, int maxThreshold)
void	CompactionStrategyManager.mutateRepaired(Collection<SSTableReader> sstables, long repairedAt, TimeUUID pendingRepair, boolean isTransient)	Mutates sstable repairedAt times and notifies listeners of the change with the writeLock held.
void	CompactionManager.performAnticompaction(ColumnFamilyStore cfs, RangesAtEndpoint replicas, Refs<SSTableReader> validatedForRepair, LifecycleTransaction txn, TimeUUID sessionID, BooleanSupplier isCancelled)	Make sure the {validatedForRepair} are marked for compaction before calling this.
CompactionManager.AllSSTableOpStatus	CompactionManager.performSSTableRewrite(ColumnFamilyStore cfs, Predicate<SSTableReader> sstableFilter, int jobs)	Perform SSTable rewrite
boolean	CompactionTask.reduceScopeForLimitedSpace(Set<SSTableReader> nonExpiredSSTables, long expectedSize)
boolean	LeveledCompactionTask.reduceScopeForLimitedSpace(Set<SSTableReader> nonExpiredSSTables, long expectedSize)
void	AbstractCompactionStrategy.removeSSTables(Iterable<SSTableReader> removed)	Removes sstables from the strategy, implementations must be able to handle the sstables having already been removed.
void	LeveledManifest.replace(Collection<SSTableReader> removed, Collection<SSTableReader> added)
void	AbstractCompactionStrategy.replaceSSTables(Collection<SSTableReader> removed, Collection<SSTableReader> added)	Replaces sstables in the compaction strategy Note that implementations must be able to handle duplicate notifications here (that removed are already gone and added have already been added)
void	LeveledCompactionStrategy.replaceSSTables(Collection<SSTableReader> removed, Collection<SSTableReader> added)
default long	ShardTracker.shardAdjustedKeyCount(Set<SSTableReader> sstables)
Future<Void>	CompactionManager.submitPendingAntiCompaction(ColumnFamilyStore cfs, RangesAtEndpoint tokenRanges, Refs<SSTableReader> sstables, LifecycleTransaction txn, TimeUUID sessionId, BooleanSupplier isCancelled)	Splits the given token ranges of the given sstables into a pending repair silo
void	CompactionManager.waitForCessation(Iterable<ColumnFamilyStore> cfss, Predicate<SSTableReader> sstablePredicate)

Constructor parameters in org.apache.cassandra.db.compaction with type arguments of type SSTableReader

Modifier	Constructor	Description
	CompactionCandidate(Collection<SSTableReader> sstables, int level, long maxSSTableBytes)
	CompactionController(ColumnFamilyStore cfs, Set<SSTableReader> compacting, long gcBefore)
	CompactionController(ColumnFamilyStore cfs, Set<SSTableReader> compacting, long gcBefore, com.google.common.util.concurrent.RateLimiter limiter, CompactionParams.TombstoneOption tombstoneOption)
	CompactionInfo(TableMetadata metadata, OperationType tasktype, long completed, long total, CompactionInfo.Unit unit, TimeUUID compactionId, Collection<? extends SSTableReader> sstables, String targetDirectory)
	CompactionInfo(TableMetadata metadata, OperationType tasktype, long completed, long total, TimeUUID compactionId, Collection<? extends SSTableReader> sstables)
	CompactionInfo(TableMetadata metadata, OperationType tasktype, long completed, long total, TimeUUID compactionId, Collection<SSTableReader> sstables, String targetDirectory)
	MultiSetBucket(UnifiedCompactionStrategy.Level level, List<Set<SSTableReader>> overlapSets)
	SimpleBucket(UnifiedCompactionStrategy.Level level, Collection<SSTableReader> sstables)
	TimeWindowCompactionController(ColumnFamilyStore cfs, Set<SSTableReader> compacting, long gcBefore, boolean ignoreOverlaps)

Uses of SSTableReader in org.apache.cassandra.db.compaction.unified

Methods in org.apache.cassandra.db.compaction.unified that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
Collection<SSTableReader>	ShardedMultiWriter.finish(boolean openResult)
Collection<SSTableReader>	ShardedMultiWriter.finished()

Method parameters in org.apache.cassandra.db.compaction.unified with type arguments of type SSTableReader

Modifier and Type	Method	Description
CompactionAwareWriter	UnifiedCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables)

Constructor parameters in org.apache.cassandra.db.compaction.unified with type arguments of type SSTableReader

Modifier	Constructor	Description
	ShardedCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, boolean keepOriginals, ShardTracker boundaries)

Uses of SSTableReader in org.apache.cassandra.db.compaction.writers

Fields in org.apache.cassandra.db.compaction.writers with type parameters of type SSTableReader

Modifier and Type	Field	Description
protected final Set<SSTableReader>	CompactionAwareWriter.nonExpiredSSTables

Methods in org.apache.cassandra.db.compaction.writers that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
Collection<SSTableReader>	CompactionAwareWriter.finish()	we are done, return the finished sstables so that the caller can mark the old ones as compacted

Method parameters in org.apache.cassandra.db.compaction.writers with type arguments of type SSTableReader

Modifier and Type	Method	Description
Directories.DataDirectory	CompactionAwareWriter.getWriteDirectory(Iterable<SSTableReader> sstables, long estimatedWriteSize)	Return a directory where we can expect expectedWriteSize to fit.

Constructor parameters in org.apache.cassandra.db.compaction.writers with type arguments of type SSTableReader

Modifier	Constructor	Description
	CompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, boolean keepOriginals)
	DefaultCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables)
	DefaultCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, boolean keepOriginals, int sstableLevel)
	MajorLeveledCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize)
	MajorLeveledCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize, boolean keepOriginals)
	MaxSSTableSizeWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize, int level)
	MaxSSTableSizeWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize, int level, boolean keepOriginals)
	SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables)
	SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, long smallestSSTable)

Uses of SSTableReader in org.apache.cassandra.db.lifecycle

Methods in org.apache.cassandra.db.lifecycle that return SSTableReader

Modifier and Type	Method	Description
SSTableReader	ILifecycleTransaction.current(SSTableReader reader)
SSTableReader	LifecycleTransaction.current(SSTableReader reader)	return the current version of the provided reader, whether or not it is visible or staged; i.e.
SSTableReader	WrappedLifecycleTransaction.current(SSTableReader reader)
SSTableReader	LifecycleTransaction.onlyOne()
static SSTableReader	LifecycleTransaction.ReaderState.visible(SSTableReader reader, com.google.common.base.Predicate<SSTableReader> obsolete, Collection<SSTableReader>... selectFrom)

Methods in org.apache.cassandra.db.lifecycle that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
Iterable<SSTableReader>	View.allKnownSSTables()
static List<Interval<PartitionPosition,SSTableReader>>	SSTableIntervalTree.buildIntervals(Collection<SSTableReader> sstables)
static Interval<PartitionPosition,SSTableReader>[]	SSTableIntervalTree.buildIntervalsArray(Collection<SSTableReader> sstables)
Iterable<SSTableReader>	LifecycleTransaction.current()	returns the currently visible readers managed by this transaction
Set<SSTableReader>	Tracker.getCompacting()
Iterable<SSTableReader>	Tracker.getUncompacting()
Iterable<SSTableReader>	Tracker.getUncompacting(Iterable<SSTableReader> candidates)
Iterable<SSTableReader>	View.getUncompacting(Iterable<SSTableReader> candidates)
Set<SSTableReader>	View.liveSSTables()
Iterable<SSTableReader>	View.liveSSTablesInBounds(PartitionPosition left, PartitionPosition right)	Returns the sstables that have any partition between left and right, when both bounds are taken inclusively.
Set<SSTableReader>	ILifecycleTransaction.originals()
Set<SSTableReader>	LifecycleTransaction.originals()	the set of readers guarded by this transaction _in their original instance/state_ call current(SSTableReader) on any reader in this set to get the latest instance
Set<SSTableReader>	WrappedLifecycleTransaction.originals()
Iterable<SSTableReader>	View.select(SSTableSet sstableSet)
static com.google.common.base.Function<View,Iterable<SSTableReader>>	View.select(SSTableSet sstableSet, com.google.common.base.Predicate<SSTableReader> filter)
static com.google.common.base.Function<View,Iterable<SSTableReader>>	View.select(SSTableSet sstableSet, DecoratedKey key)
static com.google.common.base.Function<View,Iterable<SSTableReader>>	View.selectFunction(SSTableSet sstableSet)
static com.google.common.base.Function<View,Iterable<SSTableReader>>	View.selectLive(AbstractBounds<PartitionPosition> rowBounds)
Iterable<SSTableReader>	View.sstables(SSTableSet sstableSet, com.google.common.base.Predicate<SSTableReader> filter)
static List<SSTableReader>	View.sstablesInBounds(PartitionPosition left, PartitionPosition right, SSTableIntervalTree intervalTree)

Methods in org.apache.cassandra.db.lifecycle with parameters of type SSTableReader

Modifier and Type	Method	Description
void	LifecycleTransaction.cancel(SSTableReader cancel)	remove the reader from the set we're modifying
SSTableReader	ILifecycleTransaction.current(SSTableReader reader)
SSTableReader	LifecycleTransaction.current(SSTableReader reader)	return the current version of the provided reader, whether or not it is visible or staged; i.e.
SSTableReader	WrappedLifecycleTransaction.current(SSTableReader reader)
boolean	ILifecycleTransaction.isObsolete(SSTableReader reader)
boolean	LifecycleTransaction.isObsolete(SSTableReader reader)	indicates if the reader has been marked for obsoletion
boolean	WrappedLifecycleTransaction.isObsolete(SSTableReader reader)
void	Tracker.notifyDeleting(SSTableReader deleting)
void	Tracker.notifySSTableMetadataChanged(SSTableReader levelChanged, StatsMetadata oldMetadata)
void	ILifecycleTransaction.obsolete(SSTableReader reader)
void	LifecycleTransaction.obsolete(SSTableReader reader)	mark this reader as for obsoletion : on checkpoint() the reader will be removed from the live set
void	WrappedLifecycleTransaction.obsolete(SSTableReader reader)
static LifecycleTransaction	LifecycleTransaction.offline(OperationType operationType, SSTableReader reader)	construct a Transaction for use in an offline operation
LifecycleTransaction.ReaderState	LifecycleTransaction.state(SSTableReader reader)
LifecycleTransaction	Tracker.tryModify(SSTableReader sstable, OperationType operationType)
void	ILifecycleTransaction.update(SSTableReader reader, boolean original)
void	LifecycleTransaction.update(SSTableReader reader, boolean original)	update a reader: if !original, this is a reader that is being introduced by this transaction; otherwise it must be in the originals() set, i.e.
void	WrappedLifecycleTransaction.update(SSTableReader reader, boolean original)
static SSTableReader	LifecycleTransaction.ReaderState.visible(SSTableReader reader, com.google.common.base.Predicate<SSTableReader> obsolete, Collection<SSTableReader>... selectFrom)

Method parameters in org.apache.cassandra.db.lifecycle with type arguments of type SSTableReader

Modifier and Type	Method	Description
void	Tracker.addInitialSSTables(Collection<SSTableReader> sstables)
void	Tracker.addInitialSSTablesWithoutUpdatingSize(Collection<SSTableReader> sstables)
void	Tracker.addSSTables(Collection<SSTableReader> sstables)
static List<Interval<PartitionPosition,SSTableReader>>	SSTableIntervalTree.buildIntervals(Collection<SSTableReader> sstables)
static Interval<PartitionPosition,SSTableReader>[]	SSTableIntervalTree.buildIntervalsArray(Collection<SSTableReader> sstables)
static SSTableIntervalTree	SSTableIntervalTree.buildSSTableIntervalTree(Collection<SSTableReader> sstables)
void	LifecycleTransaction.cancel(Iterable<SSTableReader> cancels)	remove the readers from the set we're modifying
Throwable	Tracker.dropSSTables(com.google.common.base.Predicate<SSTableReader> remove, OperationType operationType, Throwable accumulate)	removes all sstables that are not busy compacting.
Iterable<SSTableReader>	Tracker.getUncompacting(Iterable<SSTableReader> candidates)
Iterable<SSTableReader>	View.getUncompacting(Iterable<SSTableReader> candidates)
void	Tracker.maybeIncrementallyBackup(Iterable<SSTableReader> sstables)
void	Tracker.notifySSTableRepairedStatusChanged(Collection<SSTableReader> repairStatusesChanged)
static LifecycleTransaction	LifecycleTransaction.offline(OperationType operationType, Collection<SSTableReader> readers)	construct a Transaction for use in an offline operation
void	Tracker.removeUnsafe(Set<SSTableReader> toRemove)
void	Tracker.replaceFlushed(Memtable memtable, Collection<SSTableReader> sstables)
static com.google.common.base.Function<View,Iterable<SSTableReader>>	View.select(SSTableSet sstableSet, com.google.common.base.Predicate<SSTableReader> filter)
LifecycleTransaction	LifecycleTransaction.split(Collection<SSTableReader> readers)	remove the provided readers from this Transaction, and return a new Transaction to manage them only permitted to be called if the current Transaction has never been used
Iterable<SSTableReader>	View.sstables(SSTableSet sstableSet, com.google.common.base.Predicate<SSTableReader> filter)
LifecycleTransaction	Tracker.tryModify(Iterable<? extends SSTableReader> sstables, OperationType operationType)
void	ILifecycleTransaction.update(Collection<SSTableReader> readers, boolean original)
void	LifecycleTransaction.update(Collection<SSTableReader> readers, boolean original)
static SSTableIntervalTree	SSTableIntervalTree.update(SSTableIntervalTree tree, Collection<SSTableReader> removals, Collection<SSTableReader> additions)
void	WrappedLifecycleTransaction.update(Collection<SSTableReader> readers, boolean original)
void	Tracker.updateInitialSSTableSize(Iterable<SSTableReader> sstables)
static SSTableReader	LifecycleTransaction.ReaderState.visible(SSTableReader reader, com.google.common.base.Predicate<SSTableReader> obsolete, Collection<SSTableReader>... selectFrom)

Constructors in org.apache.cassandra.db.lifecycle with parameters of type SSTableReader

Modifier	Constructor	Description
	ReaderState(LifecycleTransaction.ReaderState.Action logged, LifecycleTransaction.ReaderState.Action staged, SSTableReader currentlyVisible, SSTableReader nextVisible, boolean original)

Uses of SSTableReader in org.apache.cassandra.db.repair

Methods in org.apache.cassandra.db.repair that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
static Refs<SSTableReader>	CassandraValidationIterator.getSSTablesToValidate(ColumnFamilyStore cfs, SharedContext ctx, Collection<Range<Token>> ranges, TimeUUID parentId, boolean isIncremental)

Uses of SSTableReader in org.apache.cassandra.db.rows

Constructors in org.apache.cassandra.db.rows with parameters of type SSTableReader

Modifier	Constructor	Description
	UnfilteredRowIteratorWithLowerBound(DecoratedKey partitionKey, SSTableReader sstable, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener)
	UnfilteredRowIteratorWithLowerBound(DecoratedKey partitionKey, SSTableReader sstable, Slices slices, boolean isReverseOrder, ColumnFilter selectedColumns, SSTableReadsListener listener)

Uses of SSTableReader in org.apache.cassandra.db.streaming

Fields in org.apache.cassandra.db.streaming declared as SSTableReader

Modifier and Type	Field	Description
protected final SSTableReader	CassandraStreamWriter.sstable

Fields in org.apache.cassandra.db.streaming with type parameters of type SSTableReader

Modifier and Type	Field	Description
protected final Collection<SSTableReader>	CassandraStreamReceiver.sstables

Methods in org.apache.cassandra.db.streaming that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
Ref<SSTableReader>	CassandraOutgoingFile.getRef()

Methods in org.apache.cassandra.db.streaming with parameters of type SSTableReader

Modifier and Type	Method	Description
boolean	CassandraOutgoingFile.contained(List<SSTableReader.PartitionPositionBounds> sections, SSTableReader sstable)

Constructors in org.apache.cassandra.db.streaming with parameters of type SSTableReader

Modifier	Constructor	Description
	CassandraCompressedStreamWriter(SSTableReader sstable, CassandraStreamHeader header, StreamSession session)
	CassandraEntireSSTableStreamWriter(SSTableReader sstable, StreamSession session, ComponentContext context)
	CassandraStreamWriter(SSTableReader sstable, CassandraStreamHeader header, StreamSession session)

Constructor parameters in org.apache.cassandra.db.streaming with type arguments of type SSTableReader

Modifier	Constructor	Description
	CassandraOutgoingFile(StreamOperation operation, Ref<SSTableReader> ref, List<SSTableReader.PartitionPositionBounds> sections, List<Range<Token>> normalizedRanges, long estimatedKeys)

Uses of SSTableReader in org.apache.cassandra.index

Method parameters in org.apache.cassandra.index with type arguments of type SSTableReader

Modifier and Type	Method	Description
void	SecondaryIndexManager.buildSSTableAttachedIndexesBlocking(Collection<SSTableReader> sstables)	Incrementally builds indexes for the specified SSTables in a blocking fashion.
SecondaryIndexBuilder	Index.CollatedViewIndexBuildingSupport.getIndexBuildTask(ColumnFamilyStore cfs, Set<Index> indexes, Collection<SSTableReader> sstables, boolean isFullRebuild)
SecondaryIndexBuilder	Index.IndexBuildingSupport.getIndexBuildTask(ColumnFamilyStore cfs, Set<Index> indexes, Collection<SSTableReader> sstables, boolean isFullRebuild)
default boolean	Index.Group.validateSSTableAttachedIndexes(Collection<SSTableReader> sstables, boolean throwOnIncomplete, boolean validateChecksum)	Validates all indexes in the group against the specified SSTables.
boolean	SecondaryIndexManager.validateSSTableAttachedIndexes(Collection<SSTableReader> sstables, boolean throwOnIncomplete, boolean validateChecksum)	Validates all index groups against the specified SSTables.

Uses of SSTableReader in org.apache.cassandra.index.internal

Constructor parameters in org.apache.cassandra.index.internal with type arguments of type SSTableReader

Modifier	Constructor	Description
	CollatedViewIndexBuilder(ColumnFamilyStore cfs, Set<Index> indexers, ReducingKeyIterator iter, Collection<SSTableReader> sstables)

Uses of SSTableReader in org.apache.cassandra.index.sai

Fields in org.apache.cassandra.index.sai declared as SSTableReader

Modifier and Type	Field	Description
final SSTableReader	SSTableContext.sstable

Methods in org.apache.cassandra.index.sai that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
static List<List<SSTableReader>>	StorageAttachedIndex.groupBySize(List<SSTableReader> toRebuild, int parallelism)	Splits SSTables into groups of similar overall size.
Pair<Set<SSTableContext>,Set<SSTableReader>>	SSTableContextManager.update(Collection<SSTableReader> removed, Iterable<SSTableReader> added, IndexValidation validation)	Initialize SSTableContexts if they are not already initialized.

Methods in org.apache.cassandra.index.sai with parameters of type SSTableReader

Modifier and Type	Method	Description
static SSTableContext	SSTableContext.create(SSTableReader sstable)
static Set<Component>	StorageAttachedIndexGroup.getLiveComponents(SSTableReader sstable, Collection<StorageAttachedIndex> indices)

Method parameters in org.apache.cassandra.index.sai with type arguments of type SSTableReader

Modifier and Type	Method	Description
void	StorageAttachedIndex.drop(Collection<SSTableReader> sstablesToRebuild)
static List<List<SSTableReader>>	StorageAttachedIndex.groupBySize(List<SSTableReader> toRebuild, int parallelism)	Splits SSTables into groups of similar overall size.
Collection<SSTableContext>	StorageAttachedIndex.onSSTableChanged(Collection<SSTableReader> oldSSTables, Collection<SSTableContext> newSSTables, IndexValidation validation)
void	SSTableContextManager.release(Collection<SSTableReader> toRelease)
Pair<Set<SSTableContext>,Set<SSTableReader>>	SSTableContextManager.update(Collection<SSTableReader> removed, Iterable<SSTableReader> added, IndexValidation validation)	Initialize SSTableContexts if they are not already initialized.
Pair<Set<SSTableContext>,Set<SSTableReader>>	SSTableContextManager.update(Collection<SSTableReader> removed, Iterable<SSTableReader> added, IndexValidation validation)	Initialize SSTableContexts if they are not already initialized.
boolean	StorageAttachedIndexGroup.validateSSTableAttachedIndexes(Collection<SSTableReader> sstables, boolean throwOnIncomplete, boolean validateChecksum)

Uses of SSTableReader in org.apache.cassandra.index.sai.disk

Methods in org.apache.cassandra.index.sai.disk that return SSTableReader

Modifier and Type	Method	Description
SSTableReader	SSTableIndex.getSSTable()

Uses of SSTableReader in org.apache.cassandra.index.sai.disk.format

Methods in org.apache.cassandra.index.sai.disk.format with parameters of type SSTableReader

Modifier and Type	Method	Description
static IndexDescriptor	IndexDescriptor.create(SSTableReader sstable)
PrimaryKeyMap.Factory	IndexDescriptor.newPrimaryKeyMapFactory(SSTableReader sstable)
PrimaryKeyMap.Factory	OnDiskFormat.newPrimaryKeyMapFactory(IndexDescriptor indexDescriptor, SSTableReader sstable)	Returns a PrimaryKeyMap.Factory for the SSTable

Uses of SSTableReader in org.apache.cassandra.index.sai.disk.v1

Methods in org.apache.cassandra.index.sai.disk.v1 with parameters of type SSTableReader

Modifier and Type	Method	Description
PrimaryKeyMap.Factory	V1OnDiskFormat.newPrimaryKeyMapFactory(IndexDescriptor indexDescriptor, SSTableReader sstable)

Constructors in org.apache.cassandra.index.sai.disk.v1 with parameters of type SSTableReader

Modifier	Constructor	Description
	Factory(IndexDescriptor indexDescriptor, SSTableReader sstable)

Uses of SSTableReader in org.apache.cassandra.index.sai.view

Methods in org.apache.cassandra.index.sai.view with parameters of type SSTableReader

Modifier and Type	Method	Description
boolean	View.containsSSTable(SSTableReader sstable)

Method parameters in org.apache.cassandra.index.sai.view with type arguments of type SSTableReader

Modifier and Type	Method	Description
void	IndexViewManager.drop(Collection<SSTableReader> sstablesToRebuild)
Collection<SSTableContext>	IndexViewManager.update(Collection<SSTableReader> oldSSTables, Collection<SSTableContext> newSSTableContexts, IndexValidation validation)	Replaces old SSTables with new by creating new immutable view.

Uses of SSTableReader in org.apache.cassandra.index.sasi

Methods in org.apache.cassandra.index.sasi that return SSTableReader

Modifier and Type	Method	Description
SSTableReader	SSTableIndex.getSSTable()

Constructors in org.apache.cassandra.index.sasi with parameters of type SSTableReader

Modifier	Constructor	Description
	SSTableIndex(ColumnIndex index, File indexFile, SSTableReader referent)

Uses of SSTableReader in org.apache.cassandra.index.sasi.conf

Methods in org.apache.cassandra.index.sasi.conf that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
Iterable<SSTableReader>	ColumnIndex.init(Set<SSTableReader> sstables)	Initialize this column index with specific set of SSTables.
Iterable<SSTableReader>	DataTracker.update(Collection<SSTableReader> oldSSTables, Collection<SSTableReader> newSSTables)	Replaces old SSTables with new by creating new immutable tracker.

Methods in org.apache.cassandra.index.sasi.conf with parameters of type SSTableReader

Modifier and Type	Method	Description
boolean	ColumnIndex.hasSSTable(SSTableReader sstable)
boolean	DataTracker.hasSSTable(SSTableReader sstable)

Method parameters in org.apache.cassandra.index.sasi.conf with type arguments of type SSTableReader

Modifier and Type	Method	Description
void	ColumnIndex.dropData(Collection<SSTableReader> sstablesToRebuild)
void	DataTracker.dropData(Collection<SSTableReader> sstablesToRebuild)
Iterable<SSTableReader>	ColumnIndex.init(Set<SSTableReader> sstables)	Initialize this column index with specific set of SSTables.
void	ColumnIndex.update(Collection<SSTableReader> oldSSTables, Collection<SSTableReader> newSSTables)
Iterable<SSTableReader>	DataTracker.update(Collection<SSTableReader> oldSSTables, Collection<SSTableReader> newSSTables)	Replaces old SSTables with new by creating new immutable tracker.

Uses of SSTableReader in org.apache.cassandra.io.sstable

Classes in org.apache.cassandra.io.sstable with type parameters of type SSTableReader

Modifier and Type	Class	Description
class	AbstractMetricsProviders<R extends SSTableReader>
class	SimpleGaugeProvider<T extends Number,R extends SSTableReader>

Fields in org.apache.cassandra.io.sstable declared as SSTableReader

Modifier and Type	Field	Description
protected final SSTableReader	AbstractSSTableIterator.sstable

Methods in org.apache.cassandra.io.sstable that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
Collection<SSTableReader>	RangeAwareSSTableWriter.finish(boolean openResult)
Collection<SSTableReader>	SimpleSSTableMultiWriter.finish(boolean openResult)
Collection<SSTableReader>	SSTableMultiWriter.finish(boolean openResult)
List<SSTableReader>	SSTableRewriter.finish()	Finishes the new file(s) Creates final files, adds the new files to the Tracker (via replaceReader).
Collection<SSTableReader>	SSTableTxnWriter.finish(boolean openResult)
Collection<SSTableReader>	SSTableZeroCopyWriter.finish(boolean openResult)
Collection<SSTableReader>	RangeAwareSSTableWriter.finished()
Collection<SSTableReader>	SimpleSSTableMultiWriter.finished()
Collection<SSTableReader>	SSTableMultiWriter.finished()
List<SSTableReader>	SSTableRewriter.finished()
Collection<SSTableReader>	SSTableZeroCopyWriter.finished()
Set<SSTableReader>	EmptySSTableScanner.getBackingSSTables()
Set<SSTableReader>	ISSTableScanner.getBackingSSTables()

Methods in org.apache.cassandra.io.sstable with parameters of type SSTableReader

Modifier and Type	Method	Description
static SSTableIdentityIterator	SSTableIdentityIterator.create(SSTableReader sstable, FileDataInput dfile, boolean tombstoneOnly)
static SSTableIdentityIterator	SSTableIdentityIterator.create(SSTableReader sstable, FileDataInput dfile, long dataPosition, DecoratedKey key, boolean tombstoneOnly)
static SSTableIdentityIterator	SSTableIdentityIterator.create(SSTableReader sstable, RandomAccessReader file, DecoratedKey key)
protected abstract R	AbstractMetricsProviders.map(SSTableReader r)
default void	SSTableReadsListener.onScanningStarted(SSTableReader sstable)	Handles notification that the specified SSTable is being scanned during a partition range query.
default void	SSTableReadsListener.onSSTableSelected(SSTableReader sstable, SSTableReadsListener.SelectionReason reason)	Handles notification that the specified SSTable has been selected during a single partition query.
default void	SSTableReadsListener.onSSTableSkipped(SSTableReader sstable, SSTableReadsListener.SkippingReason reason)	Handles notification that the specified SSTable has been skipped during a single partition query.

Method parameters in org.apache.cassandra.io.sstable with type arguments of type SSTableReader

Modifier and Type	Method	Description
CQLSSTableWriter.Builder	CQLSSTableWriter.Builder.withSSTableProducedListener(Consumer<Collection<SSTableReader>> sstableProducedListener)	Set the listener to receive notifications on sstable produced

Constructors in org.apache.cassandra.io.sstable with parameters of type SSTableReader

Modifier	Constructor	Description
protected	AbstractSSTableIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RIE indexEntry, Slices slices, ColumnFilter columnFilter, FileHandle ifile)
	EmptySSTableScanner(SSTableReader sstable)
	SSTableIdentityIterator(SSTableReader sstable, DecoratedKey key, DeletionTime partitionLevelDeletion, String filename, SSTableSimpleIterator iterator)

Constructor parameters in org.apache.cassandra.io.sstable with type arguments of type SSTableReader

Modifier	Constructor	Description
	ReducingKeyIterator(Collection<SSTableReader> sstables)
	SimpleGaugeProvider(Function<SSTableReader,R> mapper, String name, Function<Iterable<R>,T> combiner)

Uses of SSTableReader in org.apache.cassandra.io.sstable.filter

Methods in org.apache.cassandra.io.sstable.filter with parameters of type SSTableReader

Modifier and Type	Method	Description
protected R	BloomFilterMetrics.map(SSTableReader r)

Uses of SSTableReader in org.apache.cassandra.io.sstable.format

Classes in org.apache.cassandra.io.sstable.format with type parameters of type SSTableReader

Modifier and Type	Class	Description
class	AbstractSSTableFormat<R extends SSTableReader,W extends SSTableWriter>
class	SortedTableReaderLoadingBuilder<R extends SSTableReader,B extends SSTableReader.Builder<R,B>>
interface	SSTableFormat<R extends SSTableReader,W extends SSTableWriter>	Provides the accessors to data on disk.
static interface	SSTableFormat.KeyCacheValueSerializer<R extends SSTableReader,T extends AbstractRowIndexEntry>
static interface	SSTableFormat.SSTableReaderFactory<R extends SSTableReader,B extends SSTableReader.Builder<R,B>>
static class	SSTableReader.Builder<R extends SSTableReader,B extends SSTableReader.Builder<R,B>>	A builder of this sstable reader.
class	SSTableReaderLoadingBuilder<R extends SSTableReader,B extends SSTableReader.Builder<R,B>>
class	SSTableScanner<S extends SSTableReader,E extends AbstractRowIndexEntry,I extends SSTableScanner<S,E,I>.BaseKeyScanningIterator>

Subclasses of SSTableReader in org.apache.cassandra.io.sstable.format

Modifier and Type	Class	Description
class	SSTableReaderWithFilter

Fields in org.apache.cassandra.io.sstable.format declared as SSTableReader

Modifier and Type	Field	Description
protected final S	SSTableScanner.sstable

Fields in org.apache.cassandra.io.sstable.format with type parameters of type SSTableReader

Modifier and Type	Field	Description
static final Comparator<SSTableReader>	SSTableReader.firstKeyComparator
static final com.google.common.collect.Ordering<SSTableReader>	SSTableReader.firstKeyOrdering
static final Comparator<SSTableReader>	SSTableReader.idComparator
static final Comparator<SSTableReader>	SSTableReader.idReverseComparator
static final Comparator<SSTableReader>	SSTableReader.lastKeyComparator
static final Comparator<SSTableReader>	SSTableReader.maxTimestampAscending
static final Comparator<SSTableReader>	SSTableReader.maxTimestampDescending
static final Comparator<SSTableReader>	SSTableReader.sizeComparator

Methods in org.apache.cassandra.io.sstable.format that return SSTableReader

Modifier and Type	Method	Description
abstract SSTableReader	SSTableReader.cloneWithNewStart(DecoratedKey newStart)
abstract SSTableReader	SSTableReader.cloneWithRestoredStart(DecoratedKey restoredStart)
SSTableReader	SSTableWriter.finish(boolean openResult)
SSTableReader	SSTableWriter.finished()	Open the resultant SSTableReader once it has been fully written, and all related state is ready to be finalised including other sstables being written involved in the same operation
static SSTableReader	SSTableReader.moveAndOpenSSTable(ColumnFamilyStore cfs, Descriptor oldDescriptor, Descriptor newDescriptor, Set<Component> components, boolean copyData)	Moves the sstable in oldDescriptor to a new place (with generation etc) in newDescriptor.
static SSTableReader	SSTableReader.open(SSTable.Owner owner, Descriptor descriptor)
static SSTableReader	SSTableReader.open(SSTable.Owner owner, Descriptor descriptor, Set<Component> components, TableMetadataRef metadata)
static SSTableReader	SSTableReader.open(SSTable.Owner owner, Descriptor descriptor, Set<Component> components, TableMetadataRef metadata, boolean validate, boolean isOffline)	Open an SSTable for reading
static SSTableReader	SSTableReader.open(SSTable.Owner owner, Descriptor desc, TableMetadataRef metadata)
protected abstract SSTableReader	SSTableWriter.openFinal(SSTableReader.OpenReason openReason)
abstract SSTableReader	SSTableWriter.openFinalEarly()	Open the resultant SSTableReader once it has been fully written, but before the _set_ of tables that are being written together as one atomic operation are all ready
static SSTableReader	SSTableReader.openForBatch(SSTable.Owner owner, Descriptor descriptor, Set<Component> components, TableMetadataRef metadata)	Open SSTable reader to be used in batch mode(such as sstableloader).
static SSTableReader	SSTableReader.openNoValidation(Descriptor descriptor, Set<Component> components, ColumnFamilyStore cfs)
static SSTableReader	SSTableReader.openNoValidation(SSTable.Owner owner, Descriptor descriptor, TableMetadataRef metadata)

Methods in org.apache.cassandra.io.sstable.format that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
Set<SSTableReader>	SSTableScanner.getBackingSSTables()
Set<SSTableReader>	SSTableSimpleScanner.getBackingSSTables()
Interval<PartitionPosition,SSTableReader>	SSTableReader.getInterval()
static Collection<SSTableReader>	SSTableReader.openAll(SSTable.Owner owner, Set<Map.Entry<Descriptor,Set<Component>>> entries, TableMetadataRef metadata)
Ref<SSTableReader>	SSTableReader.ref()
Ref<SSTableReader>	SSTableReader.selfRef()
Ref<SSTableReader>	SSTableReader.tryRef()

Methods in org.apache.cassandra.io.sstable.format with parameters of type SSTableReader

Modifier and Type	Method	Description
int	SSTableReader.compareTo(SSTableReader other)
protected void	SortedTableVerifier.deserializeBloomFilter(SSTableReader sstable)
protected static List<AbstractBounds<PartitionPosition>>	SSTableScanner.makeBounds(SSTableReader sstable, DataRange dataRange)
void	SSTableReader.InstanceTidier.setup(SSTableReader reader, boolean trackHotness, Collection<? extends AutoCloseable> closeables)

Method parameters in org.apache.cassandra.io.sstable.format with type arguments of type SSTableReader

Modifier and Type	Method	Description
static long	SSTableReader.getApproximateKeyCount(Iterable<SSTableReader> sstables)	Calculate approximate key count.
static long	SSTableReader.getTotalBytes(Iterable<SSTableReader> sstables)
static long	SSTableReader.getTotalUncompressedBytes(Iterable<SSTableReader> sstables)
abstract void	SSTableWriter.openEarly(Consumer<SSTableReader> doWhenReady)	Open the resultant SSTableReader before it has been fully written.

Constructors in org.apache.cassandra.io.sstable.format with parameters of type SSTableReader

Modifier	Constructor	Description
	ScrubInfo(RandomAccessReader dataFile, SSTableReader sstable, Lock fileReadLock)
	SSTableSimpleScanner(SSTableReader sstable, Collection<SSTableReader.PartitionPositionBounds> boundsList)
	VerifyInfo(RandomAccessReader dataFile, SSTableReader sstable, Lock fileReadLock)

Uses of SSTableReader in org.apache.cassandra.io.sstable.format.big

Subclasses of SSTableReader in org.apache.cassandra.io.sstable.format.big

Modifier and Type	Class	Description
class	BigTableReader	SSTableReaders are open()ed by Keyspace.onStart; after that they are created by SSTableWriter.renameAndOpen.

Methods in org.apache.cassandra.io.sstable.format.big that return SSTableReader

Modifier and Type	Method	Description
SSTableReader	BigTableReader.cloneWithNewStart(DecoratedKey newStart)
SSTableReader	BigTableReader.cloneWithRestoredStart(DecoratedKey restoredStart)
SSTableReader	BigTableWriter.openFinal(SSTableReader.OpenReason openReason)
SSTableReader	BigTableWriter.openFinalEarly()

Method parameters in org.apache.cassandra.io.sstable.format.big with type arguments of type SSTableReader

Modifier and Type	Method	Description
void	BigTableWriter.openEarly(Consumer<SSTableReader> doWhenReady)

Constructors in org.apache.cassandra.io.sstable.format.big with parameters of type SSTableReader

Modifier	Constructor	Description
	SSTableIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter columns, FileHandle ifile)
	SSTableReversedIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter columns, FileHandle ifile)

Uses of SSTableReader in org.apache.cassandra.io.sstable.format.bti

Subclasses of SSTableReader in org.apache.cassandra.io.sstable.format.bti

Modifier and Type	Class	Description
class	BtiTableReader	Reader of SSTable files in BTI format (see BtiFormat), written by BtiTableWriter.

Methods in org.apache.cassandra.io.sstable.format.bti that return SSTableReader

Modifier and Type	Method	Description
protected SSTableReader	BtiTableWriter.openFinal(SSTableReader.OpenReason openReason)
SSTableReader	BtiTableWriter.openFinalEarly()

Method parameters in org.apache.cassandra.io.sstable.format.bti with type arguments of type SSTableReader

Modifier and Type	Method	Description
void	BtiTableWriter.openEarly(Consumer<SSTableReader> callWhenReady)

Uses of SSTableReader in org.apache.cassandra.io.sstable.indexsummary

Classes in org.apache.cassandra.io.sstable.indexsummary with type parameters of type SSTableReader

Modifier and Type	Class	Description
class	IndexSummaryManager<T extends SSTableReader & IndexSummarySupport<T>>	Manages the fixed-size memory pool for index summaries, periodically resizing them in order to give more memory to hot sstables and less memory to cold sstables.
class	IndexSummaryMetrics<R extends SSTableReader & IndexSummarySupport<R>>
interface	IndexSummarySupport<T extends SSTableReader & IndexSummarySupport<T>>

Methods in org.apache.cassandra.io.sstable.indexsummary with type parameters of type SSTableReader

Modifier and Type	Method	Description
static <T extends SSTableReader & IndexSummarySupport> List<T>	IndexSummaryManager.redistributeSummaries(IndexSummaryRedistribution redistribution)	Attempts to fairly distribute a fixed pool of memory for index summaries across a set of SSTables based on their recent read rates.
<T extends SSTableReader & IndexSummarySupport<T>> List<T>	IndexSummaryRedistribution.redistributeSummaries()

Methods in org.apache.cassandra.io.sstable.indexsummary with parameters of type SSTableReader

Modifier and Type	Method	Description
protected R	IndexSummaryMetrics.map(SSTableReader r)

Uses of SSTableReader in org.apache.cassandra.io.sstable.keycache

Classes in org.apache.cassandra.io.sstable.keycache with type parameters of type SSTableReader

Modifier and Type	Class	Description
class	KeyCacheMetrics<R extends SSTableReader & KeyCacheSupport<R>>
interface	KeyCacheSupport<T extends SSTableReader & KeyCacheSupport<T>>

Methods in org.apache.cassandra.io.sstable.keycache with parameters of type SSTableReader

Modifier and Type	Method	Description
protected R	KeyCacheMetrics.map(SSTableReader r)

Uses of SSTableReader in org.apache.cassandra.io.sstable.metadata

Constructor parameters in org.apache.cassandra.io.sstable.metadata with type arguments of type SSTableReader

Modifier	Constructor	Description
	MetadataCollector(Iterable<SSTableReader> sstables, ClusteringComparator comparator)

Uses of SSTableReader in org.apache.cassandra.notifications

Fields in org.apache.cassandra.notifications declared as SSTableReader

Modifier and Type	Field	Description
final SSTableReader	SSTableDeletingNotification.deleting
final SSTableReader	SSTableMetadataChanged.sstable

Fields in org.apache.cassandra.notifications with type parameters of type SSTableReader

Modifier and Type	Field	Description
final Iterable<SSTableReader>	InitialSSTableAddedNotification.added	true if the addition corresponds to the ColumnFamilyStore initialization, then the sstables are those loaded at startup.
final Iterable<SSTableReader>	SSTableAddedNotification.added	The added SSTables
final Collection<SSTableReader>	SSTableListChangedNotification.added
final Collection<SSTableReader>	SSTableListChangedNotification.removed
final Collection<SSTableReader>	SSTableRepairStatusChanged.sstables

Constructors in org.apache.cassandra.notifications with parameters of type SSTableReader

Modifier	Constructor	Description
	SSTableDeletingNotification(SSTableReader deleting)
	SSTableMetadataChanged(SSTableReader levelChanged, StatsMetadata oldMetadata)

Constructor parameters in org.apache.cassandra.notifications with type arguments of type SSTableReader

Modifier	Constructor	Description
	InitialSSTableAddedNotification(Iterable<SSTableReader> added)
	SSTableAddedNotification(Iterable<SSTableReader> added, Memtable memtable)	Creates a new SSTableAddedNotification for the specified SSTables and optional memtable.
	SSTableListChangedNotification(Collection<SSTableReader> added, Collection<SSTableReader> removed, OperationType compactionType)
	SSTableRepairStatusChanged(Collection<SSTableReader> repairStatusChanged)

Uses of SSTableReader in org.apache.cassandra.repair.consistent.admin

Methods in org.apache.cassandra.repair.consistent.admin with parameters of type SSTableReader

Modifier and Type	Method	Description
PendingStat.Builder	PendingStat.Builder.addSSTable(SSTableReader sstable)

Uses of SSTableReader in org.apache.cassandra.streaming

Methods in org.apache.cassandra.streaming that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
com.google.common.base.Predicate<SSTableReader>	PreviewKind.predicate()

Uses of SSTableReader in org.apache.cassandra.tools

Methods in org.apache.cassandra.tools that return types with arguments of type SSTableReader

Modifier and Type	Method	Description
static com.google.common.collect.Multimap<SSTableReader,SSTableReader>	SSTableExpiredBlockers.checkForExpiredSSTableBlockers(Iterable<SSTableReader> sstables, long gcBefore)
static com.google.common.collect.Multimap<SSTableReader,SSTableReader>	SSTableExpiredBlockers.checkForExpiredSSTableBlockers(Iterable<SSTableReader> sstables, long gcBefore)

Method parameters in org.apache.cassandra.tools with type arguments of type SSTableReader

Modifier and Type	Method	Description
static com.google.common.collect.Multimap<SSTableReader,SSTableReader>	SSTableExpiredBlockers.checkForExpiredSSTableBlockers(Iterable<SSTableReader> sstables, long gcBefore)