Package org.apache.cassandra.db.compaction

Interface CompactionManagerMBean

  • All Known Implementing Classes:
    CompactionManager
    public interface CompactionManagerMBean

    • Method Detail

      • getCompactions

        java.util.List<java.util.Map<java.lang.String,​java.lang.String>> getCompactions()
        List of running compaction objects.

      • getCompactionSummary

        java.util.List<java.lang.String> getCompactionSummary()
        List of running compaction summary strings.

      • getCompactionHistory

        javax.management.openmbean.TabularData getCompactionHistory()
        compaction history

      • forceUserDefinedCompaction

        void forceUserDefinedCompaction​(java.lang.String dataFiles)
        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.
        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

        void forceUserDefinedCleanup​(java.lang.String dataFiles)
        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
        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.

      • stopCompaction

        void stopCompaction​(java.lang.String type)
        Stop all running compaction-like tasks having the provided type.
        Parameters:
        type - the type of compaction to stop. Can be one of: - COMPACTION - VALIDATION - CLEANUP - SCRUB - INDEX_BUILD

      • stopCompactionById

        void stopCompactionById​(java.lang.String compactionId)
        Stop an individual running compaction using the compactionId.
        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.

      • getCoreCompactorThreads

        int getCoreCompactorThreads()
        Returns core size of compaction thread pool

      • setCoreCompactorThreads

        void setCoreCompactorThreads​(int number)
        Allows user to resize maximum size of the compaction thread pool.
        Parameters:
        number - New maximum of compaction threads

      • getMaximumCompactorThreads

        int getMaximumCompactorThreads()
        Returns maximum size of compaction thread pool

      • setMaximumCompactorThreads

        void setMaximumCompactorThreads​(int number)
        Allows user to resize maximum size of the compaction thread pool.
        Parameters:
        number - New maximum of compaction threads

      • getCoreValidationThreads

        int getCoreValidationThreads()
        Returns core size of validation thread pool

      • setCoreValidationThreads

        void setCoreValidationThreads​(int number)
        Allows user to resize maximum size of the compaction thread pool.
        Parameters:
        number - New maximum of compaction threads

      • getMaximumValidatorThreads

        int getMaximumValidatorThreads()
        Returns size of validator thread pool

      • setMaximumValidatorThreads

        void setMaximumValidatorThreads​(int number)
        Allows user to resize maximum size of the validator thread pool.
        Parameters:
        number - New maximum of validator threads

      • getCoreViewBuildThreads

        int getCoreViewBuildThreads()
        Returns core size of view build thread pool

      • getDisableSTCSInL0

        boolean getDisableSTCSInL0()
        Enable / disable STCS in L0

      • setDisableSTCSInL0

        void setDisableSTCSInL0​(boolean disabled)

      • setCoreViewBuildThreads

        void setCoreViewBuildThreads​(int number)
        Allows user to resize maximum size of the view build thread pool.
        Parameters:
        number - New maximum of view build threads

      • getMaximumViewBuildThreads

        int getMaximumViewBuildThreads()
        Returns size of view build thread pool

      • setMaximumViewBuildThreads

        void setMaximumViewBuildThreads​(int number)
        Allows user to resize maximum size of the view build thread pool.
        Parameters:
        number - New maximum of view build threads

      • getAutomaticSSTableUpgradeEnabled

        boolean getAutomaticSSTableUpgradeEnabled()
        Get automatic sstable upgrade enabled

      • setAutomaticSSTableUpgradeEnabled

        void setAutomaticSSTableUpgradeEnabled​(boolean enabled)
        Set if automatic sstable upgrade should be enabled

      • getMaxConcurrentAutoUpgradeTasks

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

      • setMaxConcurrentAutoUpgradeTasks

        void setMaxConcurrentAutoUpgradeTasks​(int value)
        Set the number of concurrent sstable upgrade tasks we should run when automatic sstable upgrades are enabled