Package org.apache.cassandra.io.sstable
Class IndexSummaryRedistribution
- java.lang.Object
-
- org.apache.cassandra.db.compaction.CompactionInfo.Holder
-
- org.apache.cassandra.io.sstable.IndexSummaryRedistribution
-
public class IndexSummaryRedistribution extends CompactionInfo.Holder
-
-
Constructor Summary
Constructors Constructor Description IndexSummaryRedistribution(java.util.Map<TableId,LifecycleTransaction> transactions, long nonRedistributingOffHeapSize, long memoryPoolBytes)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompactionInfogetCompactionInfo()booleanisGlobal()if this compaction involves several/all tables we can safely check globalCompactionsPaused in isStopRequested() belowjava.util.List<SSTableReader>redistributeSummaries()-
Methods inherited from class org.apache.cassandra.db.compaction.CompactionInfo.Holder
isStopRequested, stop
-
-
-
-
Constructor Detail
-
IndexSummaryRedistribution
public IndexSummaryRedistribution(java.util.Map<TableId,LifecycleTransaction> transactions, long nonRedistributingOffHeapSize, long memoryPoolBytes)
- Parameters:
transactions- the transactions for the different keyspaces/tables we are to redistributenonRedistributingOffHeapSize- the total index summary off heap size for all sstables we were not able to mark compacting (due to them being involved in other compactions)memoryPoolBytes- size of the memory pool
-
-
Method Detail
-
redistributeSummaries
public java.util.List<SSTableReader> redistributeSummaries() throws java.io.IOException
- Throws:
java.io.IOException
-
getCompactionInfo
public CompactionInfo getCompactionInfo()
- Specified by:
getCompactionInfoin classCompactionInfo.Holder
-
isGlobal
public boolean isGlobal()
Description copied from class:CompactionInfo.Holderif this compaction involves several/all tables we can safely check globalCompactionsPaused in isStopRequested() below- Specified by:
isGlobalin classCompactionInfo.Holder
-
-