Package org.apache.cassandra.db.compaction

Class CompactionManager

java.lang.Object

org.apache.cassandra.db.compaction.CompactionManager

All Implemented Interfaces:

CompactionManagerMBean, ICompactionManager

public class CompactionManager
extends Object
implements CompactionManagerMBean, ICompactionManager

A singleton which manages a private executor of ongoing compactions.

Scheduling for compaction is accomplished by swapping sstables to be compacted into a set via Tracker. New scheduling attempts will ignore currently compacting sstables.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	CompactionManager.AllSSTableOpStatus
static interface	CompactionManager.CompactionPauser
static class	CompactionManager.ValidationExecutor

Field Summary

Fields

Modifier and Type	Field	Description
final ActiveCompactions	active
final AtomicInteger	currentlyBackgroundUpgrading
static final int	GC_ALL
static final CompactionManager	instance
static final String	MBEAN_OBJECT_NAME
static final int	NO_GC

Constructor Summary

Constructors

Constructor	Description
CompactionManager()

Method Summary

Modifier and Type	Method	Description
static SSTableWriter	createWriter(ColumnFamilyStore cfs, File compactionFileLocation, long expectedBloomFilterSize, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SSTableReader sstable, LifecycleTransaction txn)
static SSTableWriter	createWriterForAntiCompaction(ColumnFamilyStore cfs, File compactionFileLocation, int expectedBloomFilterSize, long repairedAt, TimeUUID pendingRepair, boolean isTransient, Collection<SSTableReader> sstables, ILifecycleTransaction txn)
void	disableAutoCompaction()
void	finishCompactionsAndShutdown(long timeout, TimeUnit unit)
void	forceCompaction(ColumnFamilyStore cfStore, Supplier<Collection<SSTableReader>> sstablesFn, com.google.common.base.Predicate<SSTableReader> sstablesPredicate)
void	forceCompactionForKey(ColumnFamilyStore cfStore, DecoratedKey key)
void	forceCompactionForKeys(ColumnFamilyStore cfStore, Collection<DecoratedKey> keys)
void	forceCompactionForTokenRange(ColumnFamilyStore cfStore, Collection<Range<Token>> ranges)	Forces a major compaction of specified token ranges of the specified column family.
void	forceShutdown()	Shutdowns both compaction and validation executors, cancels running compaction / validation, and waits for tasks to complete if tasks were not cancelable.
void	forceUserDefinedCleanup(String dataFiles)	Triggers the cleanup of user specified sstables.
void	forceUserDefinedCompaction(String dataFiles)	Triggers the compaction of user specified sstables.
int	getActiveCompactions()
static CompactionIterator	getAntiCompactionIterator(List<ISSTableScanner> scanners, CompactionController controller, long nowInSec, TimeUUID timeUUID, ActiveCompactionsTracker activeCompactions, BooleanSupplier isCancelled)
boolean	getAutomaticSSTableUpgradeEnabled()	Get automatic sstable upgrade enabled
org.apache.cassandra.db.compaction.CompactionManager.BackgroundCompactionCandidate	getBackgroundCompactionCandidate(ColumnFamilyStore cfs)
TabularData	getCompactionHistory()	compaction history
List<Map<String,String>>	getCompactions()	List of running compaction objects.
List<CompactionInfo.Holder>	getCompactionsMatching(Iterable<TableMetadata> columnFamilies, Predicate<CompactionInfo> predicate)
List<String>	getCompactionSummary()	List of running compaction summary strings.
long	getCompletedTasks()
int	getCoreCompactorThreads()	Returns core size of compaction thread pool
int	getCoreSecondaryIndexExecutorThreads()
int	getCoreValidationThreads()	Returns core size of validation thread pool
int	getCoreViewBuildThreads()	Returns core size of view build thread pool
static long	getDefaultGcBefore(ColumnFamilyStore cfs, long nowInSec)
boolean	getDisableSTCSInL0()	Enable / disable STCS in L0
int	getMaxConcurrentAutoUpgradeTasks()	Get the number of concurrent sstable upgrade tasks we should run when automatic sstable upgrades are enabled
int	getMaximumCompactorThreads()	Returns maximum size of compaction thread pool
int	getMaximumSecondaryIndexExecutorThreads()
int	getMaximumValidatorThreads()	Returns size of validator thread pool
int	getMaximumViewBuildThreads()	Returns size of view build thread pool
CompactionMetrics	getMetrics()
int	getPendingTasks()
com.google.common.util.concurrent.RateLimiter	getRateLimiter()	Gets compaction rate limiter.
List<CompactionInfo>	getSSTableTasks()
long	getTotalBytesCompacted()
long	getTotalCompactionsCompleted()
boolean	hasOngoingOrPendingTasks()
void	incrementAborted()
void	incrementCompactionsReduced()
void	incrementSstablesDropppedFromCompactions(long num)
void	interruptCompactionFor(Iterable<TableMetadata> columnFamilies, Predicate<SSTableReader> sstablePredicate, boolean interruptValidation)	Try to stop all of the compactions for given ColumnFamilies.
void	interruptCompactionForCFs(Iterable<ColumnFamilyStore> cfss, Predicate<SSTableReader> sstablePredicate, boolean interruptValidation)
boolean	isCompacting(Iterable<ColumnFamilyStore> cfses, Predicate<SSTableReader> sstablePredicate)
static boolean	isCompactor(Thread thread)
boolean	isGlobalCompactionPaused()	Return whether "global" compactions should be paused, used by ColumnFamilyStore#runWithCompactionsDisabled a global compaction is one that includes several/all tables, currently only IndexSummaryBuilder
static boolean	needsCleanup(SSTableReader sstable, Collection<Range<Token>> ownedRanges)	Determines if a cleanup would actually remove any data in this SSTable based on a set of owned ranges.
CompactionManager.CompactionPauser	pauseGlobalCompaction()
void	performAnticompaction(ColumnFamilyStore cfs, RangesAtEndpoint replicas, Refs<SSTableReader> validatedForRepair, LifecycleTransaction txn, TimeUUID sessionID, BooleanSupplier isCancelled)	Make sure the {validatedForRepair} are marked for compaction before calling this.
CompactionManager.AllSSTableOpStatus	performCleanup(ColumnFamilyStore cfStore, int jobs)
CompactionManager.AllSSTableOpStatus	performGarbageCollection(ColumnFamilyStore cfStore, CompactionParams.TombstoneOption tombstoneOption, int jobs)
void	performMaximal(ColumnFamilyStore cfStore, boolean splitOutput)
CompactionManager.AllSSTableOpStatus	performScrub(ColumnFamilyStore cfs, IScrubber.Options options, int jobs)
CompactionManager.AllSSTableOpStatus	performSSTableRewrite(ColumnFamilyStore cfs, boolean skipIfCurrentVersion, long skipIfOlderThanTimestamp, boolean skipIfCompressionMatches, int jobs)
CompactionManager.AllSSTableOpStatus	performSSTableRewrite(ColumnFamilyStore cfs, Predicate<SSTableReader> sstableFilter, int jobs)	Perform SSTable rewrite
CompactionManager.AllSSTableOpStatus	performVerify(ColumnFamilyStore cfs, IVerifier.Options options)
CompactionManager.AllSSTableOpStatus	relocateSSTables(ColumnFamilyStore cfs, int jobs)
<T, E extends Throwable> T	runAsActiveCompaction(CompactionInfo.Holder activeCompactionInfo, net.openhft.chronicle.core.util.ThrowingSupplier<T,E> callable)
void	setAutomaticSSTableUpgradeEnabled(boolean enabled)	Set if automatic sstable upgrade should be enabled
void	setConcurrentCompactors(int value)
void	setConcurrentIndexBuilders(int value)
void	setConcurrentValidations()
void	setConcurrentViewBuilders(int value)
void	setCoreCompactorThreads(int number)	Allows user to resize maximum size of the compaction thread pool.
void	setCoreSecondaryIndexExecutorThreads(int number)
void	setCoreValidationThreads(int number)	Allows user to resize maximum size of the compaction thread pool.
void	setCoreViewBuildThreads(int number)	Allows user to resize maximum size of the view build thread pool.
void	setDisableSTCSInL0(boolean disabled)
void	setMaxConcurrentAutoUpgradeTasks(int value)	Set the number of concurrent sstable upgrade tasks we should run when automatic sstable upgrades are enabled
void	setMaximumCompactorThreads(int number)	Allows user to resize maximum size of the compaction thread pool.
void	setMaximumSecondaryIndexExecutorThreads(int number)
void	setMaximumValidatorThreads(int number)	Allows user to resize maximum size of the validator thread pool.
void	setMaximumViewBuildThreads(int number)	Allows user to resize maximum size of the view build thread pool.
void	setRate(double throughputMbPerSec)	Deprecated. Use setRateInBytes instead See CASSANDRA-17225
void	setRateInBytes(double throughputBytesPerSec)	Sets the rate for the rate limiter.
void	stopCompaction(String type)	Stop all running compaction-like tasks having the provided type.
void	stopCompactionById(String compactionId)	Stop an individual running compaction using the compactionId.
List<Future<?>>	submitBackground(ColumnFamilyStore cfs)	Call this whenever a compaction might be needed on the given columnfamily.
Future<?>	submitCacheWrite(AutoSavingCache.Writer writer)
Future<?>	submitIndexBuild(SecondaryIndexBuilder builder)	Is not scheduled, because it is performing disjoint work from sstable compaction.
List<Future<?>>	submitMaximal(ColumnFamilyStore cfStore, long gcBefore, boolean splitOutput)
List<Future<?>>	submitMaximal(ColumnFamilyStore cfStore, long gcBefore, boolean splitOutput, OperationType operationType)
Future<Void>	submitPendingAntiCompaction(ColumnFamilyStore cfs, RangesAtEndpoint tokenRanges, Refs<SSTableReader> sstables, LifecycleTransaction txn, TimeUUID sessionId, BooleanSupplier isCancelled)	Splits the given token ranges of the given sstables into a pending repair silo
Future<?>	submitUserDefined(ColumnFamilyStore cfs, Collection<Descriptor> dataFiles, long gcBefore)
Future<?>	submitValidation(Callable<Object> validation)
Future<Long>	submitViewBuilder(ViewBuilderTask task)
void	waitForCessation(Iterable<ColumnFamilyStore> cfss, Predicate<SSTableReader> sstablePredicate)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MBEAN_OBJECT_NAME

public static final String MBEAN_OBJECT_NAME

See Also:

• Constant Field Values

instance

public static final CompactionManager instance

currentlyBackgroundUpgrading

public final AtomicInteger currentlyBackgroundUpgrading

NO_GC

public static final int NO_GC

See Also:

• Constant Field Values

GC_ALL

public static final int GC_ALL

See Also:

• Constant Field Values

active

public final ActiveCompactions active

Constructor Details

CompactionManager

public CompactionManager()

Method Details

getMetrics

public CompactionMetrics getMetrics()

getRateLimiter

public com.google.common.util.concurrent.RateLimiter getRateLimiter()

Gets compaction rate limiter. Rate unit is bytes per sec.

Returns:

RateLimiter with rate limit set

setRate

@Deprecated(since="4.1")
public void setRate(double throughputMbPerSec)

Deprecated.

Use setRateInBytes instead See CASSANDRA-17225

Sets the rate for the rate limiter. When compaction_throughput is 0 or node is bootstrapping, this sets the rate to Double.MAX_VALUE bytes per second.

Parameters:

throughputMbPerSec - throughput to set in MiB/s

setRateInBytes

public void setRateInBytes(double throughputBytesPerSec)

Sets the rate for the rate limiter. When compaction_throughput is 0 or node is bootstrapping, this sets the rate to Double.MAX_VALUE bytes per second.

Parameters:

throughputBytesPerSec - throughput to set in B/s

submitBackground

public List<Future<?>> submitBackground(ColumnFamilyStore cfs)

Call this whenever a compaction might be needed on the given columnfamily. It's okay to over-call (within reason) if a call is unnecessary, it will turn into a no-op in the bucketing/candidate-scan phase.

isCompacting

public boolean isCompacting(Iterable<ColumnFamilyStore> cfses,
 Predicate<SSTableReader> sstablePredicate)

hasOngoingOrPendingTasks

public boolean hasOngoingOrPendingTasks()

forceShutdown

public void forceShutdown()

Shutdowns both compaction and validation executors, cancels running compaction / validation, and waits for tasks to complete if tasks were not cancelable.

finishCompactionsAndShutdown

public void finishCompactionsAndShutdown(long timeout,
 TimeUnit unit)
                                  throws InterruptedException

Throws:

InterruptedException

getBackgroundCompactionCandidate

public org.apache.cassandra.db.compaction.CompactionManager.BackgroundCompactionCandidate getBackgroundCompactionCandidate(ColumnFamilyStore cfs)

performScrub

public CompactionManager.AllSSTableOpStatus performScrub(ColumnFamilyStore cfs,
 IScrubber.Options options,
 int jobs)

performVerify

public CompactionManager.AllSSTableOpStatus performVerify(ColumnFamilyStore cfs,
 IVerifier.Options options)
                                                   throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

performSSTableRewrite

public CompactionManager.AllSSTableOpStatus performSSTableRewrite(ColumnFamilyStore cfs,
 boolean skipIfCurrentVersion,
 long skipIfOlderThanTimestamp,
 boolean skipIfCompressionMatches,
 int jobs)
                                                           throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

performSSTableRewrite

public CompactionManager.AllSSTableOpStatus performSSTableRewrite(ColumnFamilyStore cfs,
 Predicate<SSTableReader> sstableFilter,
 int jobs)
                                                           throws InterruptedException,
ExecutionException

Perform SSTable rewrite

Parameters:

sstableFilter - sstables for which predicate returns {@link false} will be excluded

Throws:

InterruptedException

ExecutionException

performCleanup

public CompactionManager.AllSSTableOpStatus performCleanup(ColumnFamilyStore cfStore,
 int jobs)
                                                    throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

performGarbageCollection

public CompactionManager.AllSSTableOpStatus performGarbageCollection(ColumnFamilyStore cfStore,
 CompactionParams.TombstoneOption tombstoneOption,
 int jobs)
                                                              throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

relocateSSTables

public CompactionManager.AllSSTableOpStatus relocateSSTables(ColumnFamilyStore cfs,
 int jobs)
                                                      throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

submitPendingAntiCompaction

public Future<Void> submitPendingAntiCompaction(ColumnFamilyStore cfs,
 RangesAtEndpoint tokenRanges,
 Refs<SSTableReader> sstables,
 LifecycleTransaction txn,
 TimeUUID sessionId,
 BooleanSupplier isCancelled)

Splits the given token ranges of the given sstables into a pending repair silo

performAnticompaction

public void performAnticompaction(ColumnFamilyStore cfs,
 RangesAtEndpoint replicas,
 Refs<SSTableReader> validatedForRepair,
 LifecycleTransaction txn,
 TimeUUID sessionID,
 BooleanSupplier isCancelled)
                           throws IOException

Make sure the {validatedForRepair} are marked for compaction before calling this. Caller must reference the validatedForRepair sstables (via ParentRepairSession.getActiveRepairedSSTableRefs(..)).

Parameters:

cfs -

replicas - token ranges to be repaired

validatedForRepair - SSTables containing the repaired ranges. Should be referenced before passing them.

sessionID - the repair session we're anti-compacting for

isCancelled - function that indicates if active anti-compaction should be canceled

Throws:

InterruptedException

IOException

performMaximal

public void performMaximal(ColumnFamilyStore cfStore,
 boolean splitOutput)

submitMaximal

public List<Future<?>> submitMaximal(ColumnFamilyStore cfStore,
 long gcBefore,
 boolean splitOutput)

submitMaximal

public List<Future<?>> submitMaximal(ColumnFamilyStore cfStore,
 long gcBefore,
 boolean splitOutput,
 OperationType operationType)

forceCompaction

public void forceCompaction(ColumnFamilyStore cfStore,
 Supplier<Collection<SSTableReader>> sstablesFn,
 com.google.common.base.Predicate<SSTableReader> sstablesPredicate)

forceCompactionForTokenRange

public void forceCompactionForTokenRange(ColumnFamilyStore cfStore,
 Collection<Range<Token>> ranges)

Forces a major compaction of specified token ranges of the specified column family.

The token ranges will be interpreted as closed intervals to match the closed interval defined by the first and last keys of a sstable, even though the Range class is suppossed to be half-open by definition.

Parameters:

cfStore - The column family store to be compacted.

ranges - The token ranges to be compacted, interpreted as closed intervals.

forceCompactionForKey

public void forceCompactionForKey(ColumnFamilyStore cfStore,
 DecoratedKey key)

forceCompactionForKeys

public void forceCompactionForKeys(ColumnFamilyStore cfStore,
 Collection<DecoratedKey> keys)

forceUserDefinedCompaction

public void forceUserDefinedCompaction(String dataFiles)

Description copied from interface: CompactionManagerMBean

Triggers the compaction of user specified sstables. You can specify files from various keyspaces and columnfamilies. If you do so, user defined compaction is performed several times to the groups of files in the same keyspace/columnfamily.

Specified by:

forceUserDefinedCompaction in interface CompactionManagerMBean

Parameters:

dataFiles - a comma separated list of sstable file to compact. must contain keyspace and columnfamily name in path(for 2.1+) or file name itself.

forceUserDefinedCleanup

public void forceUserDefinedCleanup(String dataFiles)

Description copied from interface: CompactionManagerMBean

Triggers the cleanup of user specified sstables. You can specify files from various keyspaces and columnfamilies. If you do so, cleanup is performed each file individually

Specified by:

forceUserDefinedCleanup in interface CompactionManagerMBean

Parameters:

dataFiles - a comma separated list of sstable file to cleanup. must contain keyspace and columnfamily name in path(for 2.1+) or file name itself.

submitUserDefined

public Future<?> submitUserDefined(ColumnFamilyStore cfs,
 Collection<Descriptor> dataFiles,
 long gcBefore)

submitValidation

public Future<?> submitValidation(Callable<Object> validation)

disableAutoCompaction

public void disableAutoCompaction()

needsCleanup

public static boolean needsCleanup(SSTableReader sstable,
 Collection<Range<Token>> ownedRanges)

Determines if a cleanup would actually remove any data in this SSTable based on a set of owned ranges.

createWriter

public static SSTableWriter createWriter(ColumnFamilyStore cfs,
 File compactionFileLocation,
 long expectedBloomFilterSize,
 long repairedAt,
 TimeUUID pendingRepair,
 boolean isTransient,
 SSTableReader sstable,
 LifecycleTransaction txn)

createWriterForAntiCompaction

public static SSTableWriter createWriterForAntiCompaction(ColumnFamilyStore cfs,
 File compactionFileLocation,
 int expectedBloomFilterSize,
 long repairedAt,
 TimeUUID pendingRepair,
 boolean isTransient,
 Collection<SSTableReader> sstables,
 ILifecycleTransaction txn)

getAntiCompactionIterator

public static CompactionIterator getAntiCompactionIterator(List<ISSTableScanner> scanners,
 CompactionController controller,
 long nowInSec,
 TimeUUID timeUUID,
 ActiveCompactionsTracker activeCompactions,
 BooleanSupplier isCancelled)

submitIndexBuild

public Future<?> submitIndexBuild(SecondaryIndexBuilder builder)

Is not scheduled, because it is performing disjoint work from sstable compaction.

submitCacheWrite

public Future<?> submitCacheWrite(AutoSavingCache.Writer writer)

runAsActiveCompaction

public <T,
E extends Throwable> T runAsActiveCompaction(CompactionInfo.Holder activeCompactionInfo,
 net.openhft.chronicle.core.util.ThrowingSupplier<T,E> callable)
                                                throws E

Throws:

E extends Throwable

getDefaultGcBefore

public static long getDefaultGcBefore(ColumnFamilyStore cfs,
 long nowInSec)

submitViewBuilder

public Future<Long> submitViewBuilder(ViewBuilderTask task)

getActiveCompactions

public int getActiveCompactions()

isCompactor

public static boolean isCompactor(Thread thread)

incrementAborted

public void incrementAborted()

incrementCompactionsReduced

public void incrementCompactionsReduced()

incrementSstablesDropppedFromCompactions

public void incrementSstablesDropppedFromCompactions(long num)

getCompactions

public List<Map<String,String>> getCompactions()

Description copied from interface: CompactionManagerMBean

List of running compaction objects.

Specified by:

getCompactions in interface CompactionManagerMBean

getCompactionSummary

public List<String> getCompactionSummary()

Description copied from interface: CompactionManagerMBean

List of running compaction summary strings.

Specified by:

getCompactionSummary in interface CompactionManagerMBean

getCompactionHistory

public TabularData getCompactionHistory()

Description copied from interface: CompactionManagerMBean

compaction history

Specified by:

getCompactionHistory in interface CompactionManagerMBean

getTotalBytesCompacted

public long getTotalBytesCompacted()

getTotalCompactionsCompleted

public long getTotalCompactionsCompleted()

getPendingTasks

public int getPendingTasks()

Specified by:

getPendingTasks in interface ICompactionManager

getCompletedTasks

public long getCompletedTasks()

stopCompaction

public void stopCompaction(String type)

Description copied from interface: CompactionManagerMBean

Stop all running compaction-like tasks having the provided type.

Specified by:

stopCompaction in interface CompactionManagerMBean

Parameters:

type - the type of compaction to stop. Can be one of: - COMPACTION - VALIDATION - CLEANUP - SCRUB - INDEX_BUILD

stopCompactionById

public void stopCompactionById(String compactionId)

Description copied from interface: CompactionManagerMBean

Stop an individual running compaction using the compactionId.

Specified by:

stopCompactionById in interface CompactionManagerMBean

Parameters:

compactionId - Compaction ID of compaction to stop. Such IDs can be found in the transaction log files whose name starts with compaction_, located in the table transactions folder.

setConcurrentCompactors

public void setConcurrentCompactors(int value)

setConcurrentValidations

public void setConcurrentValidations()

setConcurrentViewBuilders

public void setConcurrentViewBuilders(int value)

setConcurrentIndexBuilders

public void setConcurrentIndexBuilders(int value)

getCoreCompactorThreads

public int getCoreCompactorThreads()

Description copied from interface: CompactionManagerMBean

Returns core size of compaction thread pool

Specified by:

getCoreCompactorThreads in interface CompactionManagerMBean

setCoreCompactorThreads

public void setCoreCompactorThreads(int number)

Description copied from interface: CompactionManagerMBean

Allows user to resize maximum size of the compaction thread pool.

Specified by:

setCoreCompactorThreads in interface CompactionManagerMBean

Parameters:

number - New maximum of compaction threads

getMaximumCompactorThreads

public int getMaximumCompactorThreads()

Description copied from interface: CompactionManagerMBean

Returns maximum size of compaction thread pool

Specified by:

getMaximumCompactorThreads in interface CompactionManagerMBean

setMaximumCompactorThreads

public void setMaximumCompactorThreads(int number)

Description copied from interface: CompactionManagerMBean

Allows user to resize maximum size of the compaction thread pool.

Specified by:

setMaximumCompactorThreads in interface CompactionManagerMBean

Parameters:

number - New maximum of compaction threads

getCoreValidationThreads

public int getCoreValidationThreads()

Description copied from interface: CompactionManagerMBean

Returns core size of validation thread pool

Specified by:

getCoreValidationThreads in interface CompactionManagerMBean

setCoreValidationThreads

public void setCoreValidationThreads(int number)

Description copied from interface: CompactionManagerMBean

Allows user to resize maximum size of the compaction thread pool.

Specified by:

setCoreValidationThreads in interface CompactionManagerMBean

Parameters:

number - New maximum of compaction threads

getMaximumValidatorThreads

public int getMaximumValidatorThreads()

Description copied from interface: CompactionManagerMBean

Returns size of validator thread pool

Specified by:

getMaximumValidatorThreads in interface CompactionManagerMBean

setMaximumValidatorThreads

public void setMaximumValidatorThreads(int number)

Description copied from interface: CompactionManagerMBean

Allows user to resize maximum size of the validator thread pool.

Specified by:

setMaximumValidatorThreads in interface CompactionManagerMBean

Parameters:

number - New maximum of validator threads

getMaximumSecondaryIndexExecutorThreads

public int getMaximumSecondaryIndexExecutorThreads()

Specified by:

getMaximumSecondaryIndexExecutorThreads in interface CompactionManagerMBean

setMaximumSecondaryIndexExecutorThreads

public void setMaximumSecondaryIndexExecutorThreads(int number)

Specified by:

setMaximumSecondaryIndexExecutorThreads in interface CompactionManagerMBean

getCoreSecondaryIndexExecutorThreads

public int getCoreSecondaryIndexExecutorThreads()

Specified by:

getCoreSecondaryIndexExecutorThreads in interface CompactionManagerMBean

setCoreSecondaryIndexExecutorThreads

public void setCoreSecondaryIndexExecutorThreads(int number)

Specified by:

setCoreSecondaryIndexExecutorThreads in interface CompactionManagerMBean

getDisableSTCSInL0

public boolean getDisableSTCSInL0()

Description copied from interface: CompactionManagerMBean

Enable / disable STCS in L0

Specified by:

getDisableSTCSInL0 in interface CompactionManagerMBean

setDisableSTCSInL0

public void setDisableSTCSInL0(boolean disabled)

Specified by:

setDisableSTCSInL0 in interface CompactionManagerMBean

getCoreViewBuildThreads

public int getCoreViewBuildThreads()

Description copied from interface: CompactionManagerMBean

Returns core size of view build thread pool

Specified by:

getCoreViewBuildThreads in interface CompactionManagerMBean

setCoreViewBuildThreads

public void setCoreViewBuildThreads(int number)

Description copied from interface: CompactionManagerMBean

Allows user to resize maximum size of the view build thread pool.

Specified by:

setCoreViewBuildThreads in interface CompactionManagerMBean

Parameters:

number - New maximum of view build threads

getMaximumViewBuildThreads

public int getMaximumViewBuildThreads()

Description copied from interface: CompactionManagerMBean

Returns size of view build thread pool

Specified by:

getMaximumViewBuildThreads in interface CompactionManagerMBean

setMaximumViewBuildThreads

public void setMaximumViewBuildThreads(int number)

Description copied from interface: CompactionManagerMBean

Allows user to resize maximum size of the view build thread pool.

Specified by:

setMaximumViewBuildThreads in interface CompactionManagerMBean

Parameters:

number - New maximum of view build threads

getAutomaticSSTableUpgradeEnabled

public boolean getAutomaticSSTableUpgradeEnabled()

Description copied from interface: CompactionManagerMBean

Get automatic sstable upgrade enabled

Specified by:

getAutomaticSSTableUpgradeEnabled in interface CompactionManagerMBean

setAutomaticSSTableUpgradeEnabled

public void setAutomaticSSTableUpgradeEnabled(boolean enabled)

Description copied from interface: CompactionManagerMBean

Set if automatic sstable upgrade should be enabled

Specified by:

setAutomaticSSTableUpgradeEnabled in interface CompactionManagerMBean

getMaxConcurrentAutoUpgradeTasks

public int getMaxConcurrentAutoUpgradeTasks()

Description copied from interface: CompactionManagerMBean

Get the number of concurrent sstable upgrade tasks we should run when automatic sstable upgrades are enabled

Specified by:

getMaxConcurrentAutoUpgradeTasks in interface CompactionManagerMBean

setMaxConcurrentAutoUpgradeTasks

public void setMaxConcurrentAutoUpgradeTasks(int value)

Description copied from interface: CompactionManagerMBean

Set the number of concurrent sstable upgrade tasks we should run when automatic sstable upgrades are enabled

Specified by:

setMaxConcurrentAutoUpgradeTasks in interface CompactionManagerMBean

getCompactionsMatching

public List<CompactionInfo.Holder> getCompactionsMatching(Iterable<TableMetadata> columnFamilies,
 Predicate<CompactionInfo> predicate)

interruptCompactionFor

public void interruptCompactionFor(Iterable<TableMetadata> columnFamilies,
 Predicate<SSTableReader> sstablePredicate,
 boolean interruptValidation)

Try to stop all of the compactions for given ColumnFamilies. Note that this method does not wait for all compactions to finish; you'll need to loop against isCompacting if you want that behavior.

Parameters:

columnFamilies - The ColumnFamilies to try to stop compaction upon.

sstablePredicate - the sstable predicate to match on

interruptValidation - true if validation operations for repair should also be interrupted

interruptCompactionForCFs

public void interruptCompactionForCFs(Iterable<ColumnFamilyStore> cfss,
 Predicate<SSTableReader> sstablePredicate,
 boolean interruptValidation)

waitForCessation

public void waitForCessation(Iterable<ColumnFamilyStore> cfss,
 Predicate<SSTableReader> sstablePredicate)

getSSTableTasks

public List<CompactionInfo> getSSTableTasks()

isGlobalCompactionPaused

public boolean isGlobalCompactionPaused()

Return whether "global" compactions should be paused, used by ColumnFamilyStore#runWithCompactionsDisabled a global compaction is one that includes several/all tables, currently only IndexSummaryBuilder

pauseGlobalCompaction

public CompactionManager.CompactionPauser pauseGlobalCompaction()