Package org.apache.cassandra.io.sstable.indexsummary

Class IndexSummaryRedistribution

java.lang.Object

org.apache.cassandra.db.compaction.CompactionInfo.Holder

org.apache.cassandra.io.sstable.indexsummary.IndexSummaryRedistribution

public class IndexSummaryRedistribution
extends CompactionInfo.Holder

Constructor Summary

Constructors

Constructor	Description
IndexSummaryRedistribution(Map<TableId,LifecycleTransaction> transactions, long nonRedistributingOffHeapSize, long memoryPoolBytes)

Method Summary

Modifier and Type	Method	Description
CompactionInfo	getCompactionInfo()
boolean	isGlobal()	if this compaction involves several/all tables we can safely check globalCompactionsPaused in isStopRequested() below
<T extends SSTableReader & IndexSummarySupport<T>> List<T>	redistributeSummaries()

Methods inherited from class org.apache.cassandra.db.compaction.CompactionInfo.Holder

isStopRequested, stop

Methods inherited from class java.lang.Object

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

Constructor Details

IndexSummaryRedistribution

public IndexSummaryRedistribution(Map<TableId,LifecycleTransaction> transactions,
 long nonRedistributingOffHeapSize,
 long memoryPoolBytes)

Parameters:

transactions - the transactions for the different keyspaces/tables we are to redistribute

nonRedistributingOffHeapSize - 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 Details

redistributeSummaries

public <T extends SSTableReader & IndexSummarySupport<T>>
List<T> redistributeSummaries()
                       throws IOException

Throws:

IOException

getCompactionInfo

public CompactionInfo getCompactionInfo()

Specified by:

getCompactionInfo in class CompactionInfo.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 class CompactionInfo.Holder