Modifier and Type | Method and Description |
---|---|
LifecycleTransaction |
ColumnFamilyStore.markAllCompacting(OperationType operationType) |
Modifier and Type | Method and Description |
---|---|
java.util.List<org.apache.cassandra.db.Memtable.FlushRunnable> |
Memtable.flushRunnables(LifecycleTransaction txn) |
Modifier and Type | Field and Description |
---|---|
protected LifecycleTransaction |
AbstractCompactionTask.transaction |
Modifier and Type | Method and Description |
---|---|
static SSTableWriter |
CompactionManager.createWriter(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
long expectedBloomFilterSize,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
SSTableReader sstable,
LifecycleTransaction txn) |
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) |
AbstractCompactionTask |
AbstractCompactionStrategy.getCompactionTask(LifecycleTransaction txn,
int gcBefore,
long maxSSTableBytes) |
AbstractCompactionTask |
CompactionStrategyManager.getCompactionTask(LifecycleTransaction txn,
int gcBefore,
long maxSSTableBytes) |
AbstractCompactionTask |
LeveledCompactionStrategy.getCompactionTask(LifecycleTransaction txn,
int gcBefore,
long maxSSTableBytes) |
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.
|
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
|
Constructor and Description |
---|
AbstractCompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction transaction) |
CompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore) |
CompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore,
boolean keepOriginals) |
LeveledCompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int level,
int gcBefore,
long maxSSTableBytes,
boolean majorCompaction) |
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) |
SplittingCompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction transaction,
int sstableSizeInMB) |
SSTableSplitter(ColumnFamilyStore cfs,
LifecycleTransaction transaction,
int sstableSizeInMB) |
TimeWindowCompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore,
boolean ignoreOverlaps) |
Upgrader(ColumnFamilyStore cfs,
LifecycleTransaction txn,
OutputHandler outputHandler) |
Modifier and Type | Field and Description |
---|---|
protected LifecycleTransaction |
CompactionAwareWriter.txn |
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 |
---|---|
static LifecycleTransaction |
LifecycleTransaction.offline(OperationType operationType)
construct an empty Transaction with no existing readers
|
static LifecycleTransaction |
LifecycleTransaction.offline(OperationType operationType,
java.lang.Iterable<SSTableReader> readers)
construct a Transaction for use in an offline operation
|
static LifecycleTransaction |
LifecycleTransaction.offline(OperationType operationType,
SSTableReader reader)
construct a Transaction for use in an offline operation
|
LifecycleTransaction |
LifecycleTransaction.split(java.util.Collection<SSTableReader> readers)
remove the provided readers from this Transaction, and return a new Transaction to manage them
only permitted to be called if the current Transaction has never been used
|
LifecycleTransaction |
Tracker.tryModify(java.lang.Iterable<SSTableReader> sstables,
OperationType operationType) |
LifecycleTransaction |
Tracker.tryModify(SSTableReader sstable,
OperationType operationType) |
Constructor and Description |
---|
SSTableTxnWriter(LifecycleTransaction txn,
SSTableMultiWriter writer) |
Constructor and Description |
---|
IndexSummaryRedistribution(java.util.Map<TableId,LifecycleTransaction> transactions,
long nonRedistributingOffHeapSize,
long memoryPoolBytes) |
Copyright © 2009-2022 The Apache Software Foundation