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.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.sasi
org.apache.cassandra.index.sasi.plan
org.apache.cassandra.io.sstable
org.apache.cassandra.io.sstable.format
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 with parameters of type ColumnFamilyStore

Modifier and Type	Method	Description
Future<Pair<K,V>>	AutoSavingCache.CacheSerializer.deserialize(DataInputPlus in, ColumnFamilyStore cfs)
java.nio.ByteBuffer	CounterCacheKey.readCounterValue(ColumnFamilyStore cfs)	Reads the value of the counter represented by this key.
void	AutoSavingCache.CacheSerializer.serialize(K key, 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
ColumnFamilyStore	AbstractCompactionController.cfs
protected ColumnFamilyStore	AbstractReadCommandBuilder.cfs

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

Modifier and Type	Method	Description
static ColumnFamilyStore	ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace, java.lang.String columnFamily, TableMetadataRef metadata, boolean loadSSTables)
static ColumnFamilyStore	ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace, java.lang.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(java.lang.String cfName)
ColumnFamilyStore	Keyspace.getColumnFamilyStore(TableId id)
static ColumnFamilyStore	ColumnFamilyStore.getIfExists(java.lang.String ksName, java.lang.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 java.lang.Iterable<ColumnFamilyStore>	ColumnFamilyStore.all()
java.lang.Iterable<ColumnFamilyStore>	ColumnFamilyStore.concatWithIndexes()
java.util.Collection<ColumnFamilyStore>	Keyspace.getColumnFamilyStores()
java.lang.Iterable<ColumnFamilyStore>	Keyspace.getValidColumnFamilies(boolean allowIndexes, boolean autoAddIndexes, java.lang.String... cfNames)

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

Modifier and Type	Method	Description
DiskBoundaries	DiskBoundaryManager.getDiskBoundaries(ColumnFamilyStore cfs)
Index	ReadCommand.getIndex(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, DecoratedKey partitionKey, SSTableReader sstable, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener)
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

Constructor	Description
AbstractCompactionController(ColumnFamilyStore cfs, int gcBefore, CompactionParams.TombstoneOption tombstoneOption)
CassandraTableWriteHandler(ColumnFamilyStore cfs)
DiskBoundaries(ColumnFamilyStore cfs, Directories.DataDirectory[] directories, int diskVersion)
DiskBoundaries(ColumnFamilyStore cfs, Directories.DataDirectory[] directories, java.util.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 ColumnFamilyStore	AbstractCompactionStrategy.cfs
protected ColumnFamilyStore	AbstractCompactionTask.cfs
protected 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, java.lang.Iterable<SSTableReader> sstables, SizeTieredCompactionStrategyOptions options)
static LeveledManifest	LeveledManifest.create(ColumnFamilyStore cfs, int maxSSTableSize, int fanoutSize, java.util.List<SSTableReader> sstables)
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, java.util.Collection<SSTableReader> sstables, ILifecycleTransaction txn)
void	CompactionManager.forceCompaction(ColumnFamilyStore cfStore, java.util.function.Supplier<java.util.Collection<SSTableReader>> sstablesFn, com.google.common.base.Predicate<SSTableReader> sstablesPredicate)
void	CompactionManager.forceCompactionForKey(ColumnFamilyStore cfStore, DecoratedKey key)
void	CompactionManager.forceCompactionForTokenRange(ColumnFamilyStore cfStore, java.util.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, java.util.Set<SSTableReader> nonExpiredSSTables)
CompactionAwareWriter	CompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction transaction, java.util.Set<SSTableReader> nonExpiredSSTables)
CompactionAwareWriter	LeveledCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables)
CompactionAwareWriter	SingleSSTableLCSTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables)
CompactionAwareWriter	SSTableSplitter.SplittingCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables)
static int	CompactionManager.getDefaultGcBefore(ColumnFamilyStore cfs, int nowInSec)
static int	SizeTieredCompactionStrategy.getEstimatedCompactionsByTasks(ColumnFamilyStore cfs, java.util.List<java.util.List<SSTableReader>> tasks)
static java.util.Set<SSTableReader>	CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore, java.lang.Iterable<SSTableReader> compacting, java.lang.Iterable<SSTableReader> overlapping, int gcBefore)
static java.util.Set<SSTableReader>	CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore, java.lang.Iterable<SSTableReader> compacting, java.lang.Iterable<SSTableReader> overlapping, int 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, java.util.function.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, boolean skipCorrupted, boolean checkData, boolean reinsertOverflowedTTL, int jobs)
CompactionManager.AllSSTableOpStatus	CompactionManager.performScrub(ColumnFamilyStore cfs, boolean skipCorrupted, boolean checkData, int jobs)
CompactionManager.AllSSTableOpStatus	CompactionManager.performSSTableRewrite(ColumnFamilyStore cfs, boolean skipIfCurrentVersion, long skipIfOlderThanTimestamp, boolean skipIfCompressionMatches, int jobs)
CompactionManager.AllSSTableOpStatus	CompactionManager.performSSTableRewrite(ColumnFamilyStore cfs, java.util.function.Predicate<SSTableReader> sstableFilter, int jobs)	Perform SSTable rewrite
CompactionManager.AllSSTableOpStatus	CompactionManager.performVerify(ColumnFamilyStore cfs, Verifier.Options options)
CompactionManager.AllSSTableOpStatus	CompactionManager.relocateSSTables(ColumnFamilyStore cfs, int jobs)
java.util.List<Future<?>>	CompactionManager.submitBackground(ColumnFamilyStore cfs)	Call this whenever a compaction might be needed on the given columnfamily.
java.util.List<Future<?>>	CompactionManager.submitMaximal(ColumnFamilyStore cfStore, int gcBefore, boolean splitOutput)
Future<java.lang.Void>	CompactionManager.submitPendingAntiCompaction(ColumnFamilyStore cfs, RangesAtEndpoint tokenRanges, Refs<SSTableReader> sstables, LifecycleTransaction txn, TimeUUID sessionId, java.util.function.BooleanSupplier isCancelled)	Splits the given token ranges of the given sstables into a pending repair silo
Future<?>	CompactionManager.submitUserDefined(ColumnFamilyStore cfs, java.util.Collection<Descriptor> dataFiles, int gcBefore)

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

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

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

Constructor	Description
AbstractCompactionStrategy(ColumnFamilyStore cfs, java.util.Map<java.lang.String,java.lang.String> options)
AbstractCompactionTask(ColumnFamilyStore cfs, LifecycleTransaction transaction)
CompactionController(ColumnFamilyStore cfs, int maxValue)
CompactionController(ColumnFamilyStore cfs, java.util.Set<SSTableReader> compacting, int gcBefore)
CompactionController(ColumnFamilyStore cfs, java.util.Set<SSTableReader> compacting, int 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, java.util.function.Supplier<DiskBoundaries> boundariesSupplier, boolean partitionSSTablesByTokenRange)
CompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, int gcBefore)
CompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, int gcBefore, boolean keepOriginals)
DateTieredCompactionStrategy(ColumnFamilyStore cfs, java.util.Map<java.lang.String,java.lang.String> options)	Deprecated.
LeveledCompactionStrategy(ColumnFamilyStore cfs, java.util.Map<java.lang.String,java.lang.String> options)
LeveledCompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, int level, int gcBefore, long maxSSTableBytes, boolean majorCompaction)
PendingRepairHolder(ColumnFamilyStore cfs, AbstractStrategyHolder.DestinationRouter router, boolean isTransient)
Scrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, boolean skipCorrupted, boolean checkData)
Scrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, boolean skipCorrupted, boolean checkData, boolean reinsertOverflowedTTLRows)
Scrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, boolean skipCorrupted, OutputHandler outputHandler, boolean checkData, boolean reinsertOverflowedTTLRows)
SingleSSTableLCSTask(ColumnFamilyStore cfs, LifecycleTransaction txn, int level)
SizeTieredCompactionStrategy(ColumnFamilyStore cfs, java.util.Map<java.lang.String,java.lang.String> options)
SplitController(ColumnFamilyStore cfs)
SplittingCompactionTask(ColumnFamilyStore cfs, LifecycleTransaction transaction, int sstableSizeInMB)
SSTableSplitter(ColumnFamilyStore cfs, LifecycleTransaction transaction, int sstableSizeInMB)
TimeWindowCompactionController(ColumnFamilyStore cfs, java.util.Set<SSTableReader> compacting, int gcBefore, boolean ignoreOverlaps)
TimeWindowCompactionStrategy(ColumnFamilyStore cfs, java.util.Map<java.lang.String,java.lang.String> options)
TimeWindowCompactionTask(ColumnFamilyStore cfs, LifecycleTransaction txn, int gcBefore, boolean ignoreOverlaps)
Upgrader(ColumnFamilyStore cfs, LifecycleTransaction txn, OutputHandler outputHandler)
Verifier(ColumnFamilyStore cfs, SSTableReader sstable, boolean isOffline, Verifier.Options options)
Verifier(ColumnFamilyStore cfs, SSTableReader sstable, OutputHandler outputHandler, boolean isOffline, Verifier.Options options)

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 ColumnFamilyStore	CompactionAwareWriter.cfs

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

Constructor	Description
CompactionAwareWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, boolean keepOriginals)
DefaultCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables)
DefaultCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, boolean offline, boolean keepOriginals, int sstableLevel)	Deprecated.
DefaultCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, boolean keepOriginals, int sstableLevel)
MajorLeveledCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize)
MajorLeveledCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize, boolean keepOriginals)
MaxSSTableSizeWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize, int level)
MaxSSTableSizeWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize, int level, boolean keepOriginals)
SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables)
SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.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
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

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 java.util.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, java.util.Set<Range<Token>> ranges, TimeUUID prsId, int acquireRetrySeconds, int acquireSleepMillis)
static int	CassandraValidationIterator.getDefaultGcBefore(ColumnFamilyStore cfs, int nowInSec)
static Refs<SSTableReader>	CassandraValidationIterator.getSSTablesToValidate(ColumnFamilyStore cfs, java.util.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<java.util.List<java.lang.Void>>	CassandraKeyspaceRepairManager.prepareIncrementalRepair(TimeUUID sessionID, java.util.Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, java.util.concurrent.ExecutorService executor, java.util.function.BooleanSupplier isCancelled)

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

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

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

Constructor	Description
PendingAntiCompaction(TimeUUID prsId, java.util.Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, java.util.concurrent.ExecutorService executor, java.util.function.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 BigTableZeroCopyWriter	CassandraEntireSSTableStreamReader.createWriter(ColumnFamilyStore cfs, long totalSize, java.util.Collection<Component> components)
protected SSTableMultiWriter	CassandraStreamReader.createWriter(ColumnFamilyStore cfs, long totalSize, long repairedAt, TimeUUID pendingRepair, SSTableFormat.Type format)

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

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
java.lang.Iterable<ColumnFamilyStore>	TableViews.allViewsCfs()

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

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
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
java.util.Set<ColumnFamilyStore>	SecondaryIndexManager.getAllIndexColumnFamilyStores()
java.util.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, java.util.Set<Index> indexes, java.util.Collection<SSTableReader> sstables)
SecondaryIndexBuilder	Index.IndexBuildingSupport.getIndexBuildTask(ColumnFamilyStore cfs, java.util.Set<Index> indexes, java.util.Collection<SSTableReader> sstables)
static java.lang.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

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
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
java.util.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

Constructor	Description
CassandraIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)
CollatedViewIndexBuilder(ColumnFamilyStore cfs, java.util.Set<Index> indexers, ReducingKeyIterator iter, java.util.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

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

Constructor	Description
KeysIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)

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
java.util.Optional<ColumnFamilyStore>	SASIIndex.getBackingTable()

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

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

Constructor	Description
QueryController(ColumnFamilyStore cfs, PartitionRangeReadCommand command, long timeQuotaMs)
QueryPlan(ColumnFamilyStore cfs, ReadCommand command, long executionQuotaMs)

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

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, int sstableLevel, SerializationHeader header)
static SSTableTxnWriter	SSTableTxnWriter.create(ColumnFamilyStore cfs, Descriptor desc, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, 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
ColumnFamilyStore	RangeAwareSSTableWriter.cfs

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

Modifier and Type	Method	Description
SSTableReader	SSTableReader.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.
static SSTableReader	SSTableReader.moveAndOpenSSTable(ColumnFamilyStore cfs, Descriptor oldDescriptor, Descriptor newDescriptor, java.util.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, java.util.Set<Component> components, ColumnFamilyStore cfs)

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

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

Uses of ColumnFamilyStore in org.apache.cassandra.metrics

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

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
void	Validator.prepare(ColumnFamilyStore cfs, MerkleTrees trees, TopPartitionTracker.Collector topPartitionCollector)
java.util.concurrent.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<java.util.List<java.lang.Void>>	KeyspaceRepairManager.prepareIncrementalRepair(TimeUUID sessionID, java.util.Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, java.util.concurrent.ExecutorService executor, java.util.function.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
java.util.Iterator<ColumnFamilyStore>	SchemaArgsParser.iterator()
static java.lang.Iterable<ColumnFamilyStore>	SchemaArgsParser.parse(java.lang.String... schemaArgs)
static java.lang.Iterable<ColumnFamilyStore>	SchemaArgsParser.parse(java.util.List<java.lang.String> schemaArgs)

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

Constructor	Description
CleanupSummary(ColumnFamilyStore cfs, java.util.Set<TimeUUID> successful, java.util.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
java.util.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(java.util.List<ColumnFamilyStore> columnFamilies, RepairRunnable.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)

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
java.util.Collection<ColumnFamilyStore>	ActiveRepairService.ParentRepairSession.getColumnFamilyStores()
java.lang.Iterable<ColumnFamilyStore>	StorageService.getValidColumnFamilies(boolean allowIndexes, boolean autoAddIndexes, java.lang.String keyspaceName, java.lang.String... cfNames)

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

Modifier and Type	Method	Description
Future<Pair<CounterCacheKey,ClockAndCount>>	CacheService.CounterCacheSerializer.deserialize(DataInputPlus in, ColumnFamilyStore cfs)
Future<Pair<KeyCacheKey,RowIndexEntry>>	CacheService.KeyCacheSerializer.deserialize(DataInputPlus input, ColumnFamilyStore cfs)
Future<Pair<RowCacheKey,IRowCacheEntry>>	CacheService.RowCacheSerializer.deserialize(DataInputPlus in, ColumnFamilyStore cfs)
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
TimeUUID	ActiveRepairService.prepareForRepair(TimeUUID parentRepairSession, InetAddressAndPort coordinator, java.util.Set<InetAddressAndPort> endpoints, RepairOption options, boolean isForcedRepair, java.util.List<ColumnFamilyStore> columnFamilyStores)
void	ActiveRepairService.registerParentRepairSession(TimeUUID parentRepairSession, InetAddressAndPort coordinator, java.util.List<ColumnFamilyStore> columnFamilyStores, java.util.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

Constructor	Description
ParentRepairSession(InetAddressAndPort coordinator, java.util.List<ColumnFamilyStore> columnFamilyStores, java.util.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
ColumnFamilyStore	PaxosUncommittedIndex.baseCfs

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

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

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

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 ColumnFamilyStore	AbstractReadExecutor.cfs

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

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 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
java.util.List<OutgoingStream>	StreamSession.getOutgoingStreamsForRanges(RangesAtEndpoint replicas, java.util.Collection<ColumnFamilyStore> stores, TimeUUID pendingRepair, PreviewKind previewKind)