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 CompactionInfo
getCompactionInfo()
boolean
isGlobal()
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:
getCompactionInfo
in classCompactionInfo.Holder
-
isGlobal
public boolean isGlobal()
Description copied from class:CompactionInfo.Holder
if this compaction involves several/all tables we can safely check globalCompactionsPaused in isStopRequested() below- Specified by:
isGlobal
in classCompactionInfo.Holder
-
-