Uses of Class
org.apache.cassandra.db.ColumnFamilyStore

Packages that use ColumnFamilyStore

Package	Description
org.apache.cassandra.cache
org.apache.cassandra.db
org.apache.cassandra.db.compaction
org.apache.cassandra.db.compaction.unified
org.apache.cassandra.db.compaction.writers
org.apache.cassandra.db.filter
org.apache.cassandra.db.lifecycle
org.apache.cassandra.db.memtable
org.apache.cassandra.db.repair
org.apache.cassandra.db.streaming	File transfer
org.apache.cassandra.db.view
org.apache.cassandra.index
org.apache.cassandra.index.internal
org.apache.cassandra.index.internal.composites
org.apache.cassandra.index.internal.keys
org.apache.cassandra.index.sai
org.apache.cassandra.index.sai.plan
org.apache.cassandra.index.sasi
org.apache.cassandra.index.sasi.plan
org.apache.cassandra.io.sstable
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.metrics
org.apache.cassandra.repair
org.apache.cassandra.repair.consistent.admin
org.apache.cassandra.repair.state
org.apache.cassandra.schema
org.apache.cassandra.service
org.apache.cassandra.service.paxos.uncommitted
org.apache.cassandra.service.reads
org.apache.cassandra.service.reads.repair
org.apache.cassandra.streaming

Uses of ColumnFamilyStore in org.apache.cassandra.cache

Methods in org.apache.cassandra.cache that return ColumnFamilyStore

Modifier and Type	Method	Description
protected ColumnFamilyStore	AutoSavingCache.CacheSerializer.readCFS(DataInputPlus in)

Methods in org.apache.cassandra.cache with parameters of type ColumnFamilyStore

Modifier and Type	Method	Description
protected final int	AutoSavingCache.CacheSerializer.getOrCreateCFSOrdinal(ColumnFamilyStore cfs)
ByteBuffer	CounterCacheKey.readCounterValue(ColumnFamilyStore cfs)	Reads the value of the counter represented by this key.
abstract void	AutoSavingCache.CacheSerializer.serialize(K key, DataOutputPlus out, ColumnFamilyStore cfs)
protected void	AutoSavingCache.CacheSerializer.writeCFS(DataOutputPlus out, ColumnFamilyStore cfs)

Uses of ColumnFamilyStore in org.apache.cassandra.db

Fields in org.apache.cassandra.db declared as ColumnFamilyStore

Modifier and Type	Field	Description
final ColumnFamilyStore	AbstractCompactionController.cfs
protected final ColumnFamilyStore	AbstractReadCommandBuilder.cfs

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

Modifier and Type	Method	Description
static ColumnFamilyStore	ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace, String columnFamily, TableMetadataRef metadata, boolean loadSSTables)
static ColumnFamilyStore	ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace, String columnFamily, TableMetadataRef metadata, Directories directories, boolean loadSSTables, boolean registerBookkeeping, boolean offline)	This is only directly used by offline tools
static ColumnFamilyStore	ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace, TableMetadataRef metadata, boolean loadSSTables)
ColumnFamilyStore	Keyspace.getColumnFamilyStore(String cfName)
ColumnFamilyStore	Keyspace.getColumnFamilyStore(TableId id)
static ColumnFamilyStore	ColumnFamilyStore.getIfExists(String ksName, String cfName)	Returns a ColumnFamilyStore by ksname and cfname if it exists, null otherwise Differently from others, this method does not throw exception if the keyspace or table does not exist.
static ColumnFamilyStore	ColumnFamilyStore.getIfExists(TableId id)	Returns a ColumnFamilyStore by id if it exists, null otherwise Differently from others, this method does not throw exception if the table does not exist.
static ColumnFamilyStore	ColumnFamilyStore.getIfExists(TableMetadata table)	Returns a ColumnFamilyStore by metadata if it exists, null otherwise Differently from others, this method does not throw exception if the table does not exist.
ColumnFamilyStore	Keyspace.getIfExists(TableId id)
static ColumnFamilyStore	Keyspace.openAndGetStore(TableMetadata table)
static ColumnFamilyStore	Keyspace.openAndGetStore(TableMetadataRef tableRef)
static ColumnFamilyStore	Keyspace.openAndGetStoreIfExists(TableMetadata table)

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

Modifier and Type	Method	Description
static Iterable<ColumnFamilyStore>	ColumnFamilyStore.all()
Iterable<ColumnFamilyStore>	ColumnFamilyStore.concatWithIndexes()
Collection<ColumnFamilyStore>	Keyspace.getColumnFamilyStores()
Iterable<ColumnFamilyStore>	Keyspace.getValidColumnFamilies(boolean allowIndexes, boolean autoAddIndexes, String... cfNames)

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

Modifier and Type	Method	Description
DiskBoundaries	DiskBoundaryManager.getDiskBoundaries(ColumnFamilyStore cfs)
static org.apache.cassandra.db.DiskBoundaryManager.VersionedRangesAtEndpoint	DiskBoundaryManager.getVersionedLocalRanges(ColumnFamilyStore cfs)
void	Keyspace.initCfCustom(ColumnFamilyStore newCfs)	Registers a custom cf instance with this keyspace.
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)
UnfilteredRowIterator	SinglePartitionReadCommand.queryMemtableAndDisk(ColumnFamilyStore cfs, ColumnFamilyStore.ViewFragment view, Function<CellSourceIdentifier,Transformation<BaseRowIterator<?>>> rowTransformer, ReadExecutionController executionController)
UnfilteredRowIterator	SinglePartitionReadCommand.queryMemtableAndDisk(ColumnFamilyStore cfs, ReadExecutionController executionController)	Queries both memtable and sstables to fetch the result of this query.
UnfilteredPartitionIterator	PartitionRangeReadCommand.queryStorage(ColumnFamilyStore cfs, ReadExecutionController controller)
protected abstract UnfilteredPartitionIterator	ReadCommand.queryStorage(ColumnFamilyStore cfs, ReadExecutionController executionController)
protected UnfilteredPartitionIterator	SinglePartitionReadCommand.queryStorage(ColumnFamilyStore cfs, ReadExecutionController executionController)
static void	SystemKeyspace.saveTruncationRecord(ColumnFamilyStore cfs, long truncatedAt, CommitLogPosition position)
protected UnfilteredPartitionIterator	ReadCommand.withoutPurgeableTombstones(UnfilteredPartitionIterator iterator, ColumnFamilyStore cfs, ReadExecutionController controller)

Constructors in org.apache.cassandra.db with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	AbstractCompactionController(ColumnFamilyStore cfs, long gcBefore, CompactionParams.TombstoneOption tombstoneOption)
	CassandraTableWriteHandler(ColumnFamilyStore cfs)
	DiskBoundaries(ColumnFamilyStore cfs, Directories.DataDirectory[] directories, int diskVersion)
	DiskBoundaries(ColumnFamilyStore cfs, Directories.DataDirectory[] directories, List<PartitionPosition> positions, long ringVersion, int diskVersion)
	PartitionRangeBuilder(ColumnFamilyStore cfs)
	SinglePartitionBuilder(ColumnFamilyStore cfs, DecoratedKey key)
	SSTableImporter(ColumnFamilyStore cfs)

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

Fields in org.apache.cassandra.db.compaction declared as ColumnFamilyStore

Modifier and Type	Field	Description
protected final ColumnFamilyStore	AbstractCompactionStrategy.cfs
protected final ColumnFamilyStore	AbstractCompactionTask.cfs
protected final ColumnFamilyStore	AbstractStrategyHolder.cfs

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

Modifier and Type	Method	Description
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 ShardManager	ShardManager.create(ColumnFamilyStore cfs)
static SSTableWriter	CompactionManager.createWriter(ColumnFamilyStore cfs, File compactionFileLocation, long expectedBloomFilterSize, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SSTableReader sstable, LifecycleTransaction txn)
static SSTableWriter	CompactionManager.createWriterForAntiCompaction(ColumnFamilyStore cfs, File compactionFileLocation, int expectedBloomFilterSize, long repairedAt, TimeUUID pendingRepair, boolean isTransient, Collection<SSTableReader> sstables, ILifecycleTransaction txn)
void	CompactionManager.forceCompaction(ColumnFamilyStore cfStore, Supplier<Collection<SSTableReader>> sstablesFn, com.google.common.base.Predicate<SSTableReader> sstablesPredicate)
void	CompactionManager.forceCompactionForKey(ColumnFamilyStore cfStore, DecoratedKey key)
void	CompactionManager.forceCompactionForKeys(ColumnFamilyStore cfStore, Collection<DecoratedKey> keys)
void	CompactionManager.forceCompactionForTokenRange(ColumnFamilyStore cfStore, Collection<Range<Token>> ranges)	Forces a major compaction of specified token ranges of the specified column family.
org.apache.cassandra.db.compaction.CompactionManager.BackgroundCompactionCandidate	CompactionManager.getBackgroundCompactionCandidate(ColumnFamilyStore cfs)
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)
static long	CompactionManager.getDefaultGcBefore(ColumnFamilyStore cfs, long nowInSec)
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.
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.performCleanup(ColumnFamilyStore cfStore, int jobs)
CompactionManager.AllSSTableOpStatus	CompactionManager.performGarbageCollection(ColumnFamilyStore cfStore, CompactionParams.TombstoneOption tombstoneOption, int jobs)
void	CompactionManager.performMaximal(ColumnFamilyStore cfStore, boolean splitOutput)
CompactionManager.AllSSTableOpStatus	CompactionManager.performScrub(ColumnFamilyStore cfs, IScrubber.Options options, int jobs)
CompactionManager.AllSSTableOpStatus	CompactionManager.performSSTableRewrite(ColumnFamilyStore cfs, boolean skipIfCurrentVersion, long skipIfOlderThanTimestamp, boolean skipIfCompressionMatches, int jobs)
CompactionManager.AllSSTableOpStatus	CompactionManager.performSSTableRewrite(ColumnFamilyStore cfs, Predicate<SSTableReader> sstableFilter, int jobs)	Perform SSTable rewrite
CompactionManager.AllSSTableOpStatus	CompactionManager.performVerify(ColumnFamilyStore cfs, IVerifier.Options options)
CompactionManager.AllSSTableOpStatus	CompactionManager.relocateSSTables(ColumnFamilyStore cfs, int jobs)
List<Future<?>>	CompactionManager.submitBackground(ColumnFamilyStore cfs)	Call this whenever a compaction might be needed on the given columnfamily.
List<Future<?>>	CompactionManager.submitMaximal(ColumnFamilyStore cfStore, long gcBefore, boolean splitOutput)
List<Future<?>>	CompactionManager.submitMaximal(ColumnFamilyStore cfStore, long gcBefore, boolean splitOutput, OperationType operationType)
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
Future<?>	CompactionManager.submitUserDefined(ColumnFamilyStore cfs, Collection<Descriptor> dataFiles, long gcBefore)

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

Modifier and Type	Method	Description
void	CompactionManager.interruptCompactionForCFs(Iterable<ColumnFamilyStore> cfss, Predicate<SSTableReader> sstablePredicate, boolean interruptValidation)
boolean	CompactionManager.isCompacting(Iterable<ColumnFamilyStore> cfses, Predicate<SSTableReader> sstablePredicate)
void	CompactionManager.waitForCessation(Iterable<ColumnFamilyStore> cfss, Predicate<SSTableReader> sstablePredicate)

Constructors in org.apache.cassandra.db.compaction with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
protected	AbstractCompactionStrategy(ColumnFamilyStore cfs, Map<String,String> options)
	AbstractCompactionTask(ColumnFamilyStore cfs, LifecycleTransaction transaction)
protected	CompactionController(ColumnFamilyStore cfs, long maxValue)
	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)
	CompactionLogger(ColumnFamilyStore cfs, CompactionStrategyManager csm)
	CompactionStrategyHolder(ColumnFamilyStore cfs, AbstractStrategyHolder.DestinationRouter router, boolean isRepaired)
	CompactionStrategyManager(ColumnFamilyStore cfs)
	CompactionStrategyManager(ColumnFamilyStore cfs, Supplier<DiskBoundaries> boundariesSupplier, boolean partitionSSTablesByTokenRange)
	CompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, long gcBefore)
	CompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, long gcBefore, boolean keepOriginals)
	LeveledCompactionStrategy(ColumnFamilyStore cfs, Map<String,String> options)
	LeveledCompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, int level, long gcBefore, long maxSSTableBytes, boolean majorCompaction)
	PendingRepairHolder(ColumnFamilyStore cfs, AbstractStrategyHolder.DestinationRouter router, boolean isTransient)
	SingleSSTableLCSTask(ColumnFamilyStore cfs, LifecycleTransaction txn, int level)
	SizeTieredCompactionStrategy(ColumnFamilyStore cfs, Map<String,String> options)
	SplitController(ColumnFamilyStore cfs)
	SplittingCompactionTask(ColumnFamilyStore cfs, LifecycleTransaction transaction, int sstableSizeInMB)
	SSTableSplitter(ColumnFamilyStore cfs, LifecycleTransaction transaction, int sstableSizeInMB)
	TimeWindowCompactionController(ColumnFamilyStore cfs, Set<SSTableReader> compacting, long gcBefore, boolean ignoreOverlaps)
	TimeWindowCompactionStrategy(ColumnFamilyStore cfs, Map<String,String> options)
	TimeWindowCompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, long gcBefore, boolean ignoreOverlaps)
	UnifiedCompactionStrategy(ColumnFamilyStore cfs, Map<String,String> options)
	UnifiedCompactionStrategy(ColumnFamilyStore cfs, Map<String,String> options, Controller controller)
	Upgrader(ColumnFamilyStore cfs, LifecycleTransaction txn, OutputHandler outputHandler)

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

Fields in org.apache.cassandra.db.compaction.unified declared as ColumnFamilyStore

Modifier and Type	Field	Description
protected final ColumnFamilyStore	Controller.cfs

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

Modifier and Type	Method	Description
static Controller	Controller.fromOptions(ColumnFamilyStore cfs, Map<String,String> options)
CompactionAwareWriter	UnifiedCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables)

Constructors in org.apache.cassandra.db.compaction.unified with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	ShardedCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, boolean keepOriginals, ShardTracker boundaries)
	ShardedMultiWriter(ColumnFamilyStore cfs, Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker, ShardTracker boundaries)
	UnifiedCompactionTask(ColumnFamilyStore cfs, UnifiedCompactionStrategy strategy, LifecycleTransaction txn, long gcBefore, ShardManager shardManager)

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

Fields in org.apache.cassandra.db.compaction.writers declared as ColumnFamilyStore

Modifier and Type	Field	Description
protected final ColumnFamilyStore	CompactionAwareWriter.cfs

Constructors in org.apache.cassandra.db.compaction.writers with parameters of type ColumnFamilyStore

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 ColumnFamilyStore in org.apache.cassandra.db.filter

Methods in org.apache.cassandra.db.filter with parameters of type ColumnFamilyStore

Modifier and Type	Method	Description
abstract float	DataLimits.estimateTotalResults(ColumnFamilyStore cfs)	Estimate the number of results that a full scan of the provided cfs would yield.

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

Fields in org.apache.cassandra.db.lifecycle declared as ColumnFamilyStore

Modifier and Type	Field	Description
final ColumnFamilyStore	Tracker.cfstore

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

Modifier and Type	Method	Description
static boolean	LifecycleTransaction.removeUnfinishedLeftovers(ColumnFamilyStore cfs)

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

Modifier	Constructor	Description
	Tracker(ColumnFamilyStore columnFamilyStore, Memtable memtable, boolean loadsstables)

Uses of ColumnFamilyStore in org.apache.cassandra.db.memtable

Methods in org.apache.cassandra.db.memtable with parameters of type ColumnFamilyStore

Modifier and Type	Method	Description
static SSTableMultiWriter	Flushing.createFlushWriter(ColumnFamilyStore cfs, Memtable.FlushablePartitionSet<?> flushSet, LifecycleTransaction txn, Descriptor descriptor, long partitionCount)
static List<Flushing.FlushRunnable>	Flushing.flushRunnables(ColumnFamilyStore cfs, Memtable memtable, LifecycleTransaction txn)

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

Methods in org.apache.cassandra.db.repair with parameters of type ColumnFamilyStore

Modifier and Type	Method	Description
protected PendingAntiCompaction.AcquisitionCallable	PendingAntiCompaction.getAcquisitionCallable(ColumnFamilyStore cfs, Set<Range<Token>> ranges, TimeUUID prsId, int acquireRetrySeconds, int acquireSleepMillis)
static long	CassandraValidationIterator.getDefaultGcBefore(ColumnFamilyStore cfs, long nowInSec)
static Refs<SSTableReader>	CassandraValidationIterator.getSSTablesToValidate(ColumnFamilyStore cfs, SharedContext ctx, Collection<Range<Token>> ranges, TimeUUID parentId, boolean isIncremental)

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

Modifier and Type	Method	Description
Future<List<Void>>	CassandraKeyspaceRepairManager.prepareIncrementalRepair(TimeUUID sessionID, Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, ExecutorService executor, BooleanSupplier isCancelled)

Constructors in org.apache.cassandra.db.repair with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	AcquisitionCallable(ColumnFamilyStore cfs, Collection<Range<Token>> ranges, TimeUUID sessionID, int acquireRetrySeconds, int acquireSleepMillis)
	CassandraTableRepairManager(ColumnFamilyStore cfs)
	CassandraTableRepairManager(ColumnFamilyStore cfs, SharedContext ctx)
	CassandraValidationIterator(ColumnFamilyStore cfs, SharedContext ctx, Collection<Range<Token>> ranges, TimeUUID parentId, TimeUUID sessionID, boolean isIncremental, long nowInSec, TopPartitionTracker.Collector topPartitionCollector)

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

Modifier	Constructor	Description
	PendingAntiCompaction(TimeUUID prsId, Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, ExecutorService executor, BooleanSupplier isCancelled)

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

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

Modifier and Type	Method	Description
protected SSTableZeroCopyWriter	CassandraEntireSSTableStreamReader.createWriter(ColumnFamilyStore cfs, long totalSize, Collection<Component> components)
protected SSTableMultiWriter	CassandraStreamReader.createWriter(ColumnFamilyStore cfs, long totalSize, long repairedAt, TimeUUID pendingRepair, SSTableFormat<?,?> format)

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

Modifier	Constructor	Description
	CassandraIncomingFile(ColumnFamilyStore cfs, StreamSession session, StreamMessageHeader header)
	CassandraStreamManager(ColumnFamilyStore cfs)
	CassandraStreamReceiver(ColumnFamilyStore cfs, StreamSession session, int totalFiles)

Uses of ColumnFamilyStore in org.apache.cassandra.db.view

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

Modifier and Type	Method	Description
Iterable<ColumnFamilyStore>	TableViews.allViewsCfs()

Constructors in org.apache.cassandra.db.view with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	View(ViewMetadata definition, ColumnFamilyStore baseCfs)
	ViewBuilderTask(ColumnFamilyStore baseCfs, View view, Range<Token> range, Token lastToken, long keysBuilt)

Uses of ColumnFamilyStore in org.apache.cassandra.index

Fields in org.apache.cassandra.index declared as ColumnFamilyStore

Modifier and Type	Field	Description
final ColumnFamilyStore	SecondaryIndexManager.baseCfs	The underlying column family containing the source data for these indexes

Methods in org.apache.cassandra.index that return ColumnFamilyStore

Modifier and Type	Method	Description
static ColumnFamilyStore	SecondaryIndexManager.getParentCfs(ColumnFamilyStore cfs)	Returns the parent of the specified ColumnFamilyStore.

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

Modifier and Type	Method	Description
Set<ColumnFamilyStore>	SecondaryIndexManager.getAllIndexColumnFamilyStores()
Optional<ColumnFamilyStore>	Index.getBackingTable()	If the index implementation uses a local table to store its index data, this method should return a handle to it.

Methods in org.apache.cassandra.index with parameters of type ColumnFamilyStore

Modifier and Type	Method	Description
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)
static String	SecondaryIndexManager.getIndexName(ColumnFamilyStore cfs)	Returns the index name
static ColumnFamilyStore	SecondaryIndexManager.getParentCfs(ColumnFamilyStore cfs)	Returns the parent of the specified ColumnFamilyStore.
static boolean	SecondaryIndexManager.isIndexColumnFamilyStore(ColumnFamilyStore cfs)	Checks if the specified ColumnFamilyStore is a secondary index.

Constructors in org.apache.cassandra.index with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	SecondaryIndexManager(ColumnFamilyStore baseCfs)

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

Fields in org.apache.cassandra.index.internal declared as ColumnFamilyStore

Modifier and Type	Field	Description
final ColumnFamilyStore	CassandraIndex.baseCfs
protected ColumnFamilyStore	CassandraIndex.indexCfs

Methods in org.apache.cassandra.index.internal that return ColumnFamilyStore

Modifier and Type	Method	Description
ColumnFamilyStore	CassandraIndex.getIndexCfs()

Methods in org.apache.cassandra.index.internal that return types with arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
Optional<ColumnFamilyStore>	CassandraIndex.getBackingTable()

Methods in org.apache.cassandra.index.internal with parameters of type ColumnFamilyStore

Modifier and Type	Method	Description
static CassandraIndex	CassandraIndex.newIndex(ColumnFamilyStore baseCfs, IndexMetadata indexMetadata)	Factory method for new CassandraIndex instances
CassandraIndex	CassandraIndexFunctions.newIndexInstance(ColumnFamilyStore baseCfs, IndexMetadata indexMetadata)

Constructors in org.apache.cassandra.index.internal with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
protected	CassandraIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)
	CollatedViewIndexBuilder(ColumnFamilyStore cfs, Set<Index> indexers, ReducingKeyIterator iter, Collection<SSTableReader> sstables)

Uses of ColumnFamilyStore in org.apache.cassandra.index.internal.composites

Constructors in org.apache.cassandra.index.internal.composites with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	ClusteringColumnIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)
	CollectionEntryIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)
	CollectionKeyIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)
	CollectionKeyIndexBase(ColumnFamilyStore baseCfs, IndexMetadata indexDef)
	CollectionValueIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)
	PartitionKeyIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)
	RegularColumnIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)

Uses of ColumnFamilyStore in org.apache.cassandra.index.internal.keys

Constructors in org.apache.cassandra.index.internal.keys with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	KeysIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)

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

Methods in org.apache.cassandra.index.sai that return ColumnFamilyStore

Modifier and Type	Method	Description
ColumnFamilyStore	StorageAttachedIndex.baseCfs()
ColumnFamilyStore	StorageAttachedIndexGroup.table()

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

Modifier and Type	Method	Description
Optional<ColumnFamilyStore>	StorageAttachedIndex.getBackingTable()

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

Modifier and Type	Method	Description
static StorageAttachedIndexGroup	StorageAttachedIndexGroup.getIndexGroup(ColumnFamilyStore cfs)

Constructors in org.apache.cassandra.index.sai with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	StorageAttachedIndex(ColumnFamilyStore baseCfs, IndexMetadata indexMetadata)

Uses of ColumnFamilyStore in org.apache.cassandra.index.sai.plan

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

Modifier and Type	Method	Description
static StorageAttachedIndexQueryPlan	StorageAttachedIndexQueryPlan.create(ColumnFamilyStore cfs, TableQueryMetrics queryMetrics, Set<StorageAttachedIndex> indexes, RowFilter filter)

Constructors in org.apache.cassandra.index.sai.plan with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	QueryController(ColumnFamilyStore cfs, ReadCommand command, RowFilter indexFilter, QueryContext queryContext)
	StorageAttachedIndexSearcher(ColumnFamilyStore cfs, TableQueryMetrics tableQueryMetrics, ReadCommand command, RowFilter indexFilter, long executionQuotaMs)

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

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

Modifier and Type	Method	Description
Optional<ColumnFamilyStore>	SASIIndex.getBackingTable()

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

Modifier	Constructor	Description
	SASIIndex(ColumnFamilyStore baseCfs, IndexMetadata config)

Uses of ColumnFamilyStore in org.apache.cassandra.index.sasi.plan

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

Modifier	Constructor	Description
	QueryController(ColumnFamilyStore cfs, ReadCommand command, long timeQuotaMs)
	SASIIndexSearcher(ColumnFamilyStore cfs, ReadCommand command, long executionQuotaMs)

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

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

Modifier and Type	Field	Description
final ColumnFamilyStore	RangeAwareSSTableWriter.cfs

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

Modifier and Type	Method	Description
static SSTableRewriter	SSTableRewriter.construct(ColumnFamilyStore cfs, ILifecycleTransaction transaction, boolean keepOriginals, long maxAge)
static SSTableTxnWriter	SSTableTxnWriter.create(ColumnFamilyStore cfs, Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SerializationHeader header)
abstract com.codahale.metrics.Gauge<T>	GaugeProvider.getTableGauge(ColumnFamilyStore cfs)
com.codahale.metrics.Gauge<T>	SimpleGaugeProvider.getTableGauge(ColumnFamilyStore cfs)

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

Modifier	Constructor	Description
	RangeAwareSSTableWriter(ColumnFamilyStore cfs, long estimatedKeys, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SSTableFormat<?,?> format, int sstableLevel, long totalSize, LifecycleNewTracker lifecycleNewTracker, SerializationHeader header)

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

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

Modifier and Type	Field	Description
protected final ColumnFamilyStore	SortedTableScrubber.cfs
protected final ColumnFamilyStore	SortedTableVerifier.cfs

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

Modifier and Type	Method	Description
IScrubber	SSTableFormat.getScrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, OutputHandler outputHandler, IScrubber.Options options)	Returns a new scrubber for an sstable.
abstract IVerifier	SSTableReader.getVerifier(ColumnFamilyStore cfs, OutputHandler outputHandler, boolean isOffline, IVerifier.Options options)	Returns a new verifier for this sstable.
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.openNoValidation(Descriptor descriptor, Set<Component> components, ColumnFamilyStore cfs)

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

Modifier	Constructor	Description
protected	SortedTableScrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, OutputHandler outputHandler, IScrubber.Options options)
	SortedTableVerifier(ColumnFamilyStore cfs, R sstable, OutputHandler outputHandler, boolean isOffline, IVerifier.Options options)
	VerifyController(ColumnFamilyStore cfs)

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

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

Modifier and Type	Method	Description
BigTableReader	BigTableReader.cloneWithNewSummarySamplingLevel(ColumnFamilyStore parent, int samplingLevel)	Returns a new SSTableReader with the same properties as this SSTableReader except that a new IndexSummary will be built at the target samplingLevel.
IScrubber	BigFormat.getScrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, OutputHandler outputHandler, IScrubber.Options options)
IVerifier	BigTableReader.getVerifier(ColumnFamilyStore cfs, OutputHandler outputHandler, boolean isOffline, IVerifier.Options options)

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

Modifier	Constructor	Description
	BigTableScrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, OutputHandler outputHandler, IScrubber.Options options)
	BigTableVerifier(ColumnFamilyStore cfs, BigTableReader sstable, OutputHandler outputHandler, boolean isOffline, IVerifier.Options options)

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

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

Modifier and Type	Method	Description
IScrubber	BtiFormat.getScrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, OutputHandler outputHandler, IScrubber.Options options)
IVerifier	BtiTableReader.getVerifier(ColumnFamilyStore cfs, OutputHandler outputHandler, boolean isOffline, IVerifier.Options options)

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

Modifier	Constructor	Description
	BtiTableScrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, OutputHandler outputHandler, IScrubber.Options options)
	BtiTableVerifier(ColumnFamilyStore cfs, BtiTableReader sstable, OutputHandler outputHandler, boolean isOffline, IVerifier.Options options)

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

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

Modifier and Type	Method	Description
T	IndexSummarySupport.cloneWithNewSummarySamplingLevel(ColumnFamilyStore cfs, int newSamplingLevel)

Uses of ColumnFamilyStore in org.apache.cassandra.metrics

Methods in org.apache.cassandra.metrics that return types with arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
static Iterable<ColumnFamilyStore>	SamplingManager.getTables(String ks, String table)

Constructors in org.apache.cassandra.metrics with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	TableMetrics(ColumnFamilyStore cfs, TableMetrics.ReleasableMetric memtableMetrics)	Creates metrics for given ColumnFamilyStore.

Uses of ColumnFamilyStore in org.apache.cassandra.repair

Methods in org.apache.cassandra.repair with parameters of type ColumnFamilyStore

Modifier and Type	Method	Description
static void	ValidationManager.doValidation(ColumnFamilyStore cfs, Validator validator)	Performs a readonly "compaction" of all sstables in order to validate complete rows, but without writing the merge result
void	Validator.prepare(ColumnFamilyStore cfs, MerkleTrees trees, TopPartitionTracker.Collector topPartitionCollector)
TableRepairManager	SharedContext.ForwardingSharedContext.repairManager(ColumnFamilyStore store)
TableRepairManager	SharedContext.Global.repairManager(ColumnFamilyStore store)
TableRepairManager	SharedContext.repairManager(ColumnFamilyStore store)
Future<?>	IValidationManager.submitValidation(ColumnFamilyStore cfs, Validator validator)
Future<?>	ValidationManager.submitValidation(ColumnFamilyStore cfs, Validator validator)	Does not mutate data, so is not scheduled.

Method parameters in org.apache.cassandra.repair with type arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
Future<List<Void>>	KeyspaceRepairManager.prepareIncrementalRepair(TimeUUID sessionID, Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, ExecutorService executor, BooleanSupplier isCancelled)	Isolate the unrepaired ranges of the given tables, and make referenceable by session id.

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

Methods in org.apache.cassandra.repair.consistent.admin that return types with arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
Iterator<ColumnFamilyStore>	SchemaArgsParser.iterator()
static Iterable<ColumnFamilyStore>	SchemaArgsParser.parse(String... schemaArgs)
static Iterable<ColumnFamilyStore>	SchemaArgsParser.parse(List<String> schemaArgs)

Constructors in org.apache.cassandra.repair.consistent.admin with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	CleanupSummary(ColumnFamilyStore cfs, Set<TimeUUID> successful, Set<TimeUUID> unsuccessful)

Uses of ColumnFamilyStore in org.apache.cassandra.repair.state

Methods in org.apache.cassandra.repair.state that return types with arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
List<ColumnFamilyStore>	CoordinatorState.getColumnFamilies()

Method parameters in org.apache.cassandra.repair.state with type arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
void	CoordinatorState.Phase.start(List<ColumnFamilyStore> columnFamilies, RepairCoordinator.NeighborsAndRanges neighborsAndRanges)

Uses of ColumnFamilyStore in org.apache.cassandra.schema

Methods in org.apache.cassandra.schema that return ColumnFamilyStore

Modifier and Type	Method	Description
ColumnFamilyStore	Schema.getColumnFamilyStoreInstance(TableId id)	Returns ColumnFamilyStore by the table identifier.

Uses of ColumnFamilyStore in org.apache.cassandra.service

Methods in org.apache.cassandra.service that return types with arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
Collection<ColumnFamilyStore>	ActiveRepairService.ParentRepairSession.getColumnFamilyStores()
Iterable<ColumnFamilyStore>	StorageService.getValidColumnFamilies(boolean allowIndexes, boolean autoAddIndexes, String keyspaceName, String... cfNames)

Methods in org.apache.cassandra.service with parameters of type ColumnFamilyStore

Modifier and Type	Method	Description
void	CacheService.CounterCacheSerializer.serialize(CounterCacheKey key, DataOutputPlus out, ColumnFamilyStore cfs)
void	CacheService.KeyCacheSerializer.serialize(KeyCacheKey key, DataOutputPlus out, ColumnFamilyStore cfs)
void	CacheService.RowCacheSerializer.serialize(RowCacheKey key, DataOutputPlus out, ColumnFamilyStore cfs)

Method parameters in org.apache.cassandra.service with type arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
Future<?>	ActiveRepairService.prepareForRepair(TimeUUID parentRepairSession, InetAddressAndPort coordinator, Set<InetAddressAndPort> endpoints, RepairOption options, boolean isForcedRepair, List<ColumnFamilyStore> columnFamilyStores)
void	ActiveRepairService.registerParentRepairSession(TimeUUID parentRepairSession, InetAddressAndPort coordinator, List<ColumnFamilyStore> columnFamilyStores, Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)

Constructor parameters in org.apache.cassandra.service with type arguments of type ColumnFamilyStore

Modifier	Constructor	Description
	ParentRepairSession(InetAddressAndPort coordinator, List<ColumnFamilyStore> columnFamilyStores, Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)

Uses of ColumnFamilyStore in org.apache.cassandra.service.paxos.uncommitted

Fields in org.apache.cassandra.service.paxos.uncommitted declared as ColumnFamilyStore

Modifier and Type	Field	Description
final ColumnFamilyStore	PaxosUncommittedIndex.baseCfs

Methods in org.apache.cassandra.service.paxos.uncommitted that return types with arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
Optional<ColumnFamilyStore>	PaxosUncommittedIndex.getBackingTable()

Constructors in org.apache.cassandra.service.paxos.uncommitted with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	PaxosUncommittedIndex(ColumnFamilyStore baseTable, IndexMetadata metadata)

Uses of ColumnFamilyStore in org.apache.cassandra.service.reads

Fields in org.apache.cassandra.service.reads declared as ColumnFamilyStore

Modifier and Type	Field	Description
protected final ColumnFamilyStore	AbstractReadExecutor.cfs

Constructors in org.apache.cassandra.service.reads with parameters of type ColumnFamilyStore

Modifier	Constructor	Description
	NeverSpeculatingReadExecutor(ColumnFamilyStore cfs, ReadCommand command, ReplicaPlan.ForTokenRead replicaPlan, Dispatcher.RequestTime requestTime, boolean logFailedSpeculation)

Uses of ColumnFamilyStore in org.apache.cassandra.service.reads.repair

Fields in org.apache.cassandra.service.reads.repair declared as ColumnFamilyStore

Modifier and Type	Field	Description
protected final ColumnFamilyStore	AbstractReadRepair.cfs

Uses of ColumnFamilyStore in org.apache.cassandra.streaming

Method parameters in org.apache.cassandra.streaming with type arguments of type ColumnFamilyStore

Modifier and Type	Method	Description
List<OutgoingStream>	StreamSession.getOutgoingStreamsForRanges(RangesAtEndpoint replicas, Collection<ColumnFamilyStore> stores, TimeUUID pendingRepair, PreviewKind previewKind)