Modifier and Type | Method and Description |
---|---|
long |
ColumnFamilyStore.getExpectedCompactedFileSize(java.lang.Iterable<SSTableReader> sstables,
OperationType operation)
Calculate expected file size of SSTable after compaction.
|
LifecycleTransaction |
ColumnFamilyStore.markAllCompacting(OperationType operationType) |
void |
ColumnFamilyStore.markObsolete(java.util.Collection<SSTableReader> sstables,
OperationType compactionType) |
Modifier and Type | Field and Description |
---|---|
protected OperationType |
AbstractCompactionTask.compactionType |
Modifier and Type | Method and Description |
---|---|
static OperationType |
OperationType.fromFileName(java.lang.String fileName) |
OperationType |
CompactionInfo.getTaskType() |
static OperationType |
OperationType.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static OperationType[] |
OperationType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
AbstractCompactionTask |
AbstractCompactionTask.setCompactionType(OperationType compactionType) |
Constructor and Description |
---|
CompactionInfo(CFMetaData cfm,
OperationType tasktype,
long completed,
long total,
java.lang.String unit,
java.util.UUID compactionId) |
CompactionInfo(CFMetaData cfm,
OperationType tasktype,
long bytesComplete,
long totalBytes,
java.util.UUID compactionId) |
CompactionInfo(OperationType tasktype,
long completed,
long total,
java.lang.String unit,
java.util.UUID compactionId) |
CompactionIterator(OperationType type,
java.util.List<ISSTableScanner> scanners,
CompactionController controller,
int nowInSec,
java.util.UUID compactionId) |
CompactionIterator(OperationType type,
java.util.List<ISSTableScanner> scanners,
CompactionController controller,
int nowInSec,
java.util.UUID compactionId,
CompactionMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
OperationType |
LifecycleTransaction.opType() |
Modifier and Type | Method and Description |
---|---|
java.lang.Throwable |
Tracker.dropSSTables(com.google.common.base.Predicate<SSTableReader> remove,
OperationType operationType,
java.lang.Throwable accumulate)
removes all sstables that are not busy compacting.
|
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 |
Tracker.tryModify(java.lang.Iterable<SSTableReader> sstables,
OperationType operationType) |
LifecycleTransaction |
Tracker.tryModify(SSTableReader sstable,
OperationType operationType) |
Modifier and Type | Method and Description |
---|---|
default SSTableFlushObserver |
Index.getFlushObserver(Descriptor descriptor,
OperationType opType)
Get flush observer to observe partition/cell events generated by flushing SSTable (memtable flush or compaction).
|
Modifier and Type | Method and Description |
---|---|
SSTableFlushObserver |
SASIIndex.getFlushObserver(Descriptor descriptor,
OperationType opType) |
protected static PerSSTableIndexWriter |
SASIIndex.newWriter(AbstractType<?> keyValidator,
Descriptor descriptor,
java.util.Map<ColumnDefinition,ColumnIndex> indexes,
OperationType opType) |
Constructor and Description |
---|
PerSSTableIndexWriter(AbstractType<?> keyValidator,
Descriptor descriptor,
OperationType source,
java.util.Map<ColumnDefinition,ColumnIndex> supportedIndexes) |
Modifier and Type | Field and Description |
---|---|
OperationType |
SSTableListChangedNotification.compactionType |
Constructor and Description |
---|
SSTableListChangedNotification(java.util.Collection<SSTableReader> added,
java.util.Collection<SSTableReader> removed,
OperationType compactionType) |
Copyright © 2018 The Apache Software Foundation