Modifier and Type | Method and 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) |
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
AbstractCompactionController.cfs |
protected ColumnFamilyStore |
AbstractReadCommandBuilder.cfs |
ColumnFamilyStore |
Memtable.cfs |
Modifier and Type | Method and 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 |
Keyspace.openAndGetStore(TableMetadata table) |
static ColumnFamilyStore |
Keyspace.openAndGetStore(TableMetadataRef tableRef) |
Modifier and Type | Method and 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) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyStore |
AbstractCompactionStrategy.cfs |
protected ColumnFamilyStore |
AbstractCompactionTask.cfs |
protected ColumnFamilyStore |
AbstractStrategyHolder.cfs |
Modifier and Type | Method and 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)
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 |
SSTableSplitter.SplittingCompactionTask.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) |
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 silo
|
java.util.concurrent.Future<?> |
CompactionManager.submitUserDefined(ColumnFamilyStore cfs,
java.util.Collection<Descriptor> dataFiles,
int gcBefore) |
Modifier and Type | Method and 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) |
Constructor and 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) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyStore |
CompactionAwareWriter.cfs |
Constructor and 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) |
Modifier and Type | Method and Description |
---|---|
abstract float |
DataLimits.estimateTotalResults(ColumnFamilyStore cfs)
Estimate the number of results that a full scan of the provided cfs would yield.
|
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
Tracker.cfstore |
Modifier and Type | Method and Description |
---|---|
static boolean |
LifecycleTransaction.removeUnfinishedLeftovers(ColumnFamilyStore cfs) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and 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) |
Constructor and 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 and Description |
---|
PendingAntiCompaction(java.util.UUID prsId,
java.util.Collection<ColumnFamilyStore> tables,
RangesAtEndpoint tokenRanges,
java.util.concurrent.ExecutorService executor,
java.util.function.BooleanSupplier isCancelled) |
Modifier and Type | Method and 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) |
Constructor and Description |
---|
CassandraIncomingFile(ColumnFamilyStore cfs,
StreamSession session,
StreamMessageHeader header) |
CassandraStreamManager(ColumnFamilyStore cfs) |
CassandraStreamReceiver(ColumnFamilyStore cfs,
StreamSession session,
int totalFiles) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<ColumnFamilyStore> |
TableViews.allViewsCfs() |
Constructor and Description |
---|
View(ViewMetadata definition,
ColumnFamilyStore baseCfs) |
ViewBuilderTask(ColumnFamilyStore baseCfs,
View view,
Range<Token> range,
Token lastToken,
long keysBuilt) |
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
SecondaryIndexManager.baseCfs
The underlying column family containing the source data for these indexes
|
Modifier and Type | Method and Description |
---|---|
static ColumnFamilyStore |
SecondaryIndexManager.getParentCfs(ColumnFamilyStore cfs)
Returns the parent of the specified
ColumnFamilyStore . |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
SecondaryIndexBuilder |
Index.IndexBuildingSupport.getIndexBuildTask(ColumnFamilyStore cfs,
java.util.Set<Index> indexes,
java.util.Collection<SSTableReader> sstables) |
SecondaryIndexBuilder |
Index.CollatedViewIndexBuildingSupport.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. |
Constructor and Description |
---|
SecondaryIndexManager(ColumnFamilyStore baseCfs) |
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
CassandraIndex.baseCfs |
protected ColumnFamilyStore |
CassandraIndex.indexCfs |
Modifier and Type | Method and Description |
---|---|
ColumnFamilyStore |
CassandraIndex.getIndexCfs() |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<ColumnFamilyStore> |
CassandraIndex.getBackingTable() |
Modifier and Type | Method and Description |
---|---|
static CassandraIndex |
CassandraIndex.newIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexMetadata)
Factory method for new CassandraIndex instances
|
CassandraIndex |
CassandraIndexFunctions.newIndexInstance(ColumnFamilyStore baseCfs,
IndexMetadata indexMetadata) |
Constructor and Description |
---|
CassandraIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
CollatedViewIndexBuilder(ColumnFamilyStore cfs,
java.util.Set<Index> indexers,
ReducingKeyIterator iter,
java.util.Collection<SSTableReader> sstables) |
Constructor and 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) |
Constructor and Description |
---|
KeysIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<ColumnFamilyStore> |
SASIIndex.getBackingTable() |
Constructor and Description |
---|
SASIIndex(ColumnFamilyStore baseCfs,
IndexMetadata config) |
Constructor and Description |
---|
QueryController(ColumnFamilyStore cfs,
PartitionRangeReadCommand command,
long timeQuotaMs) |
QueryPlan(ColumnFamilyStore cfs,
ReadCommand command,
long executionQuotaMs) |
Modifier and Type | Method and 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) |
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
RangeAwareSSTableWriter.cfs |
Modifier and Type | Method and 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) |
Constructor and 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) |
Constructor and Description |
---|
TableMetrics(ColumnFamilyStore cfs)
Creates metrics for given
ColumnFamilyStore . |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<ColumnFamilyStore> |
SchemaArgsParser.iterator() |
static java.lang.Iterable<ColumnFamilyStore> |
SchemaArgsParser.parse(java.util.List<java.lang.String> schemaArgs) |
static java.lang.Iterable<ColumnFamilyStore> |
SchemaArgsParser.parse(java.lang.String... schemaArgs) |
Constructor and Description |
---|
CleanupSummary(ColumnFamilyStore cfs,
java.util.Set<java.util.UUID> successful,
java.util.Set<java.util.UUID> unsuccessful) |
Modifier and Type | Method and Description |
---|---|
ColumnFamilyStore |
Schema.getColumnFamilyStoreInstance(TableId id) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<Pair<CounterCacheKey,ClockAndCount>> |
CacheService.CounterCacheSerializer.deserialize(DataInputPlus in,
ColumnFamilyStore cfs) |
java.util.concurrent.Future<Pair<RowCacheKey,IRowCacheEntry>> |
CacheService.RowCacheSerializer.deserialize(DataInputPlus in,
ColumnFamilyStore cfs) |
java.util.concurrent.Future<Pair<KeyCacheKey,RowIndexEntry>> |
CacheService.KeyCacheSerializer.deserialize(DataInputPlus input,
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) |
Modifier and Type | Method and 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 and Description |
---|
ParentRepairSession(InetAddressAndPort coordinator,
java.util.List<ColumnFamilyStore> columnFamilyStores,
java.util.Collection<Range<Token>> ranges,
boolean isIncremental,
long repairedAt,
boolean isGlobal,
PreviewKind previewKind) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyStore |
AbstractReadExecutor.cfs |
Constructor and Description |
---|
NeverSpeculatingReadExecutor(ColumnFamilyStore cfs,
ReadCommand command,
ReplicaPlan.ForTokenRead replicaPlan,
long queryStartNanoTime,
boolean logFailedSpeculation) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyStore |
AbstractReadRepair.cfs |
Modifier and Type | Method and Description |
---|---|
java.util.List<OutgoingStream> |
StreamSession.getOutgoingStreamsForRanges(RangesAtEndpoint replicas,
java.util.Collection<ColumnFamilyStore> stores,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
Copyright © 2009-2022 The Apache Software Foundation