|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cassandra.db.CompactionManager
public class CompactionManager
Field Summary | |
---|---|
static CompactionManager |
instance
|
static java.lang.String |
MBEAN_OBJECT_NAME
|
Constructor Summary | |
---|---|
CompactionManager()
|
Method Summary | |
---|---|
void |
checkAllColumnFamilies()
|
void |
disableAutoCompaction()
|
java.lang.Long |
getBytesCompacted()
|
java.lang.Long |
getBytesTotalInProgress()
|
java.lang.String |
getColumnFamilyInProgress()
|
static int |
getDefaultGCBefore()
|
int |
getMaximumCompactionThreshold()
Gets the maximum number of sstables in queue before compaction kicks off |
int |
getMinimumCompactionThreshold()
Gets the minimum number of sstables in queue before compaction kicks off |
int |
getPendingTasks()
|
void |
setMaximumCompactionThreshold(int threshold)
Sets the maximum number of sstables in queue before compaction kicks off |
void |
setMinimumCompactionThreshold(int threshold)
Sets the minimum number of sstables in queue before compaction kicks off |
java.util.concurrent.Future<java.util.List<SSTableReader>> |
submitAnticompaction(ColumnFamilyStore cfStore,
java.util.Collection<Range> ranges,
java.net.InetAddress target)
|
java.util.concurrent.Future<java.lang.Object> |
submitCleanup(ColumnFamilyStore cfStore)
|
java.util.concurrent.Future |
submitMajor(ColumnFamilyStore cfStore)
|
java.util.concurrent.Future |
submitMajor(ColumnFamilyStore cfStore,
long skip,
int gcBefore)
|
java.util.concurrent.Future<java.lang.Integer> |
submitMinorIfNeeded(ColumnFamilyStore cfs)
Call this whenever a compaction might be needed on the given columnfamily. |
java.util.concurrent.Future |
submitValidation(ColumnFamilyStore cfStore,
AntiEntropyService.Validator validator)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String MBEAN_OBJECT_NAME
public static final CompactionManager instance
Constructor Detail |
---|
public CompactionManager()
Method Detail |
---|
public java.util.concurrent.Future<java.lang.Integer> submitMinorIfNeeded(ColumnFamilyStore cfs)
public java.util.concurrent.Future<java.lang.Object> submitCleanup(ColumnFamilyStore cfStore)
public java.util.concurrent.Future<java.util.List<SSTableReader>> submitAnticompaction(ColumnFamilyStore cfStore, java.util.Collection<Range> ranges, java.net.InetAddress target)
public java.util.concurrent.Future submitMajor(ColumnFamilyStore cfStore)
public java.util.concurrent.Future submitMajor(ColumnFamilyStore cfStore, long skip, int gcBefore)
public java.util.concurrent.Future submitValidation(ColumnFamilyStore cfStore, AntiEntropyService.Validator validator)
public int getMinimumCompactionThreshold()
getMinimumCompactionThreshold
in interface CompactionManagerMBean
public void setMinimumCompactionThreshold(int threshold)
setMinimumCompactionThreshold
in interface CompactionManagerMBean
public int getMaximumCompactionThreshold()
getMaximumCompactionThreshold
in interface CompactionManagerMBean
public void setMaximumCompactionThreshold(int threshold)
setMaximumCompactionThreshold
in interface CompactionManagerMBean
public void disableAutoCompaction()
public static int getDefaultGCBefore()
public void checkAllColumnFamilies() throws java.io.IOException
java.io.IOException
public java.lang.String getColumnFamilyInProgress()
getColumnFamilyInProgress
in interface CompactionManagerMBean
public java.lang.Long getBytesTotalInProgress()
getBytesTotalInProgress
in interface CompactionManagerMBean
public java.lang.Long getBytesCompacted()
getBytesCompacted
in interface CompactionManagerMBean
public int getPendingTasks()
getPendingTasks
in interface CompactionManagerMBean
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |