Modifier and Type | Method and Description |
---|---|
LifecycleTransaction |
ColumnFamilyStore.markAllCompacting(OperationType operationType) |
Modifier and Type | Method and Description |
---|---|
SSTableMultiWriter |
ColumnFamilyStore.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
int sstableLevel,
SerializationHeader header,
LifecycleTransaction txn) |
SSTableMultiWriter |
ColumnFamilyStore.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
MetadataCollector metadataCollector,
SerializationHeader header,
LifecycleTransaction txn) |
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 |
---|---|
SSTableMultiWriter |
AbstractCompactionStrategy.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
MetadataCollector meta,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleTransaction txn) |
SSTableMultiWriter |
CompactionStrategyManager.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
MetadataCollector collector,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleTransaction txn) |
static SSTableWriter |
CompactionManager.createWriter(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
long expectedBloomFilterSize,
long repairedAt,
SSTableReader sstable,
LifecycleTransaction txn) |
static SSTableWriter |
CompactionManager.createWriterForAntiCompaction(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
int expectedBloomFilterSize,
long repairedAt,
java.util.Collection<SSTableReader> sstables,
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) |
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,
java.util.Collection<Range<Token>> ranges,
Refs<SSTableReader> validatedForRepair,
LifecycleTransaction txn,
long repairedAt,
java.util.UUID parentRepairSession)
Make sure the {validatedForRepair} are marked for compaction before calling this.
|
Constructor and Description |
---|
AbstractCompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction transaction) |
CompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore) |
CompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore,
boolean keepOriginals) |
CompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore,
boolean offline,
boolean keepOriginals)
Deprecated.
|
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) |
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) |
CompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
boolean offline,
boolean keepOriginals)
Deprecated.
|
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) |
MajorLeveledCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
boolean offline,
boolean keepOriginals)
Deprecated.
|
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) |
MaxSSTableSizeWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
int level,
boolean offline,
boolean keepOriginals)
Deprecated.
|
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) |
Modifier and Type | Method and Description |
---|---|
static SSTableRewriter |
SSTableRewriter.construct(ColumnFamilyStore cfs,
LifecycleTransaction transaction,
boolean keepOriginals,
long maxAge) |
static SSTableRewriter |
SSTableRewriter.constructKeepingOriginals(LifecycleTransaction transaction,
boolean keepOriginals,
long maxAge) |
static SSTableRewriter |
SSTableRewriter.constructKeepingOriginals(LifecycleTransaction transaction,
boolean keepOriginals,
long maxAge,
boolean isOffline)
Deprecated.
|
static SSTableRewriter |
SSTableRewriter.constructWithoutEarlyOpening(LifecycleTransaction transaction,
boolean keepOriginals,
long maxAge) |
static SSTableMultiWriter |
SimpleSSTableMultiWriter.create(Descriptor descriptor,
long keyCount,
long repairedAt,
CFMetaData cfm,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleTransaction txn) |
Constructor and Description |
---|
SimpleSSTableMultiWriter(SSTableWriter writer,
LifecycleTransaction txn) |
SSTableRewriter(LifecycleTransaction transaction,
long maxAge,
boolean isOffline)
Deprecated.
|
SSTableRewriter(LifecycleTransaction transaction,
long maxAge,
boolean isOffline,
boolean shouldOpenEarly)
Deprecated.
|
SSTableRewriter(LifecycleTransaction transaction,
long maxAge,
long preemptiveOpenInterval,
boolean keepOriginals) |
SSTableTxnWriter(LifecycleTransaction txn,
SSTableMultiWriter writer) |
Constructor and Description |
---|
IndexSummaryRedistribution(java.util.List<SSTableReader> compacting,
java.util.Map<java.util.UUID,LifecycleTransaction> transactions,
long memoryPoolBytes) |
Modifier and Type | Method and Description |
---|---|
static SSTableWriter |
SSTableWriter.create(CFMetaData metadata,
Descriptor descriptor,
long keyCount,
long repairedAt,
int sstableLevel,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleTransaction txn) |
static SSTableWriter |
SSTableWriter.create(Descriptor descriptor,
java.lang.Long keyCount,
java.lang.Long repairedAt,
CFMetaData metadata,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleTransaction txn) |
static SSTableWriter |
SSTableWriter.create(Descriptor descriptor,
long keyCount,
long repairedAt,
int sstableLevel,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleTransaction txn) |
static SSTableWriter |
SSTableWriter.create(java.lang.String filename,
long keyCount,
long repairedAt,
int sstableLevel,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleTransaction txn) |
static SSTableWriter |
SSTableWriter.create(java.lang.String filename,
long keyCount,
long repairedAt,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleTransaction txn) |
abstract SSTableWriter |
SSTableWriter.Factory.open(Descriptor descriptor,
long keyCount,
long repairedAt,
CFMetaData metadata,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<SSTableFlushObserver> observers,
LifecycleTransaction txn) |
Constructor and Description |
---|
RangeAwareSSTableWriter(ColumnFamilyStore cfs,
long estimatedKeys,
long repairedAt,
SSTableFormat.Type format,
int sstableLevel,
long totalSize,
LifecycleTransaction txn,
SerializationHeader header) |
Constructor and Description |
---|
BigTableWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
CFMetaData metadata,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<SSTableFlushObserver> observers,
LifecycleTransaction txn) |
Modifier and Type | Method and Description |
---|---|
LifecycleTransaction |
StreamReceiveTask.getTransaction() |
LifecycleTransaction |
StreamSession.getTransaction(java.util.UUID cfId) |
Copyright © 2020 The Apache Software Foundation