Uses of Class
org.apache.cassandra.db.ColumnFamilyStore
-
-
Uses of ColumnFamilyStore in org.apache.cassandra.cache
Methods in org.apache.cassandra.cache with parameters of type ColumnFamilyStore Modifier and Type Method Description java.util.concurrent.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
ColumnFamilyStore
Memtable. 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 toolsstatic 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
Keyspace. openAndGetStore(TableMetadata table)
static ColumnFamilyStore
Keyspace. openAndGetStore(TableMetadataRef tableRef)
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)
-
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, java.io.File compactionFileLocation, long expectedBloomFilterSize, long repairedAt, java.util.UUID pendingRepair, boolean isTransient, SSTableReader sstable, LifecycleTransaction txn)
static SSTableWriter
CompactionManager. createWriterForAntiCompaction(ColumnFamilyStore cfs, java.io.File compactionFileLocation, int expectedBloomFilterSize, long repairedAt, java.util.UUID pendingRepair, boolean isTransient, java.util.Collection<SSTableReader> sstables, ILifecycleTransaction txn)
void
CompactionManager. forceCompactionForTokenRange(ColumnFamilyStore cfStore, java.util.Collection<Range<Token>> ranges)
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, java.util.UUID 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 excludeCurrentVersion, int jobs)
CompactionManager.AllSSTableOpStatus
CompactionManager. performVerify(ColumnFamilyStore cfs, Verifier.Options options)
CompactionManager.AllSSTableOpStatus
CompactionManager. relocateSSTables(ColumnFamilyStore cfs, int jobs)
java.util.List<java.util.concurrent.Future<?>>
CompactionManager. submitBackground(ColumnFamilyStore cfs)
Call this whenever a compaction might be needed on the given columnfamily.java.util.List<java.util.concurrent.Future<?>>
CompactionManager. submitMaximal(ColumnFamilyStore cfStore, int gcBefore, boolean splitOutput)
com.google.common.util.concurrent.ListenableFuture<?>
CompactionManager. submitPendingAntiCompaction(ColumnFamilyStore cfs, RangesAtEndpoint tokenRanges, Refs<SSTableReader> sstables, LifecycleTransaction txn, java.util.UUID sessionId, java.util.function.BooleanSupplier isCancelled)
Splits the given token ranges of the given sstables into a pending repair silojava.util.concurrent.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)
-
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, java.util.UUID prsId, int acquireRetrySeconds, int acquireSleepMillis)
static int
CassandraValidationIterator. getDefaultGcBefore(ColumnFamilyStore cfs, int nowInSec)
Method parameters in org.apache.cassandra.db.repair with type arguments of type ColumnFamilyStore Modifier and Type Method Description com.google.common.util.concurrent.ListenableFuture
CassandraKeyspaceRepairManager. prepareIncrementalRepair(java.util.UUID 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, java.util.UUID sessionID, int acquireRetrySeconds, int acquireSleepMillis)
CassandraTableRepairManager(ColumnFamilyStore cfs)
CassandraValidationIterator(ColumnFamilyStore cfs, java.util.Collection<Range<Token>> ranges, java.util.UUID parentId, java.util.UUID sessionID, boolean isIncremental, int nowInSec)
Constructor parameters in org.apache.cassandra.db.repair with type arguments of type ColumnFamilyStore Constructor Description PendingAntiCompaction(java.util.UUID 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, java.util.UUID 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 indexesMethods in org.apache.cassandra.index that return ColumnFamilyStore Modifier and Type Method Description static ColumnFamilyStore
SecondaryIndexManager. getParentCfs(ColumnFamilyStore cfs)
Returns the parent of the specifiedColumnFamilyStore
.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 namestatic ColumnFamilyStore
SecondaryIndexManager. getParentCfs(ColumnFamilyStore cfs)
Returns the parent of the specifiedColumnFamilyStore
.static boolean
SecondaryIndexManager. isIndexColumnFamilyStore(ColumnFamilyStore cfs)
Checks if the specifiedColumnFamilyStore
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 instancesCassandraIndex
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, java.util.UUID pendingRepair, boolean isTransient, int sstableLevel, SerializationHeader header)
static SSTableTxnWriter
SSTableTxnWriter. create(ColumnFamilyStore cfs, Descriptor desc, long keyCount, long repairedAt, java.util.UUID 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, java.util.UUID 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)
Creates metrics for givenColumnFamilyStore
. -
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 tree)
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 com.google.common.util.concurrent.ListenableFuture
KeyspaceRepairManager. prepareIncrementalRepair(java.util.UUID 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<java.util.UUID> successful, java.util.Set<java.util.UUID> unsuccessful)
-
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 java.util.concurrent.Future<Pair<CounterCacheKey,ClockAndCount>>
CacheService.CounterCacheSerializer. deserialize(DataInputPlus in, ColumnFamilyStore cfs)
java.util.concurrent.Future<Pair<KeyCacheKey,RowIndexEntry>>
CacheService.KeyCacheSerializer. deserialize(DataInputPlus input, ColumnFamilyStore cfs)
java.util.concurrent.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 java.util.UUID
ActiveRepairService. prepareForRepair(java.util.UUID parentRepairSession, InetAddressAndPort coordinator, java.util.Set<InetAddressAndPort> endpoints, RepairOption options, boolean isForcedRepair, java.util.List<ColumnFamilyStore> columnFamilyStores)
void
ActiveRepairService. registerParentRepairSession(java.util.UUID 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.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, long queryStartNanoTime, 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, java.util.UUID pendingRepair, PreviewKind previewKind)
-