Package org.apache.cassandra.db.compaction

Interface CompactionManagerMBean

All Known Implementing Classes:
CompactionManager
public interface CompactionManagerMBean

  • Method Details

    • getCompactions

      List<Map<String,String>> getCompactions()
      List of running compaction objects.

    • getCompactionSummary

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

    • getCompactionHistory

      TabularData getCompactionHistory()
      compaction history

    • forceUserDefinedCompaction

      void forceUserDefinedCompaction(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(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(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(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

    • getMaximumSecondaryIndexExecutorThreads

      int getMaximumSecondaryIndexExecutorThreads()

    • setMaximumSecondaryIndexExecutorThreads

      void setMaximumSecondaryIndexExecutorThreads(int number)

    • getCoreSecondaryIndexExecutorThreads

      int getCoreSecondaryIndexExecutorThreads()

    • setCoreSecondaryIndexExecutorThreads

      void setCoreSecondaryIndexExecutorThreads(int number)

    • 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