Package org.apache.cassandra.db.compaction

Class LeveledManifest

java.lang.Object

org.apache.cassandra.db.compaction.LeveledManifest

public class LeveledManifest
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LeveledManifest.CompactionCandidate

Method Summary

Modifier and Type	Method	Description
void	addSSTables(Iterable<SSTableReader> readers)
static LeveledManifest	create(ColumnFamilyStore cfs, int maxSSTableSize, int fanoutSize, Iterable<SSTableReader> sstables, SizeTieredCompactionStrategyOptions options)
static LeveledManifest	create(ColumnFamilyStore cfs, int maxSSTableSize, int fanoutSize, List<SSTableReader> sstables)
int[]	getAllLevelSize()
long[]	getAllLevelSizeBytes()
LeveledManifest.CompactionCandidate	getCompactionCandidates()
int	getEstimatedTasks()
int	getLevelCount()
int	getLevelSize(int i)
int	getNextLevel(Collection<SSTableReader> sstables)
Set<SSTableReader>	getSSTables()
Set<SSTableReader>[]	getSStablesPerLevelSnapshot()
static long	maxBytesForLevel(int level, int levelFanoutSize, long maxSSTableSizeInBytes)
long	maxBytesForLevel(int level, long maxSSTableSizeInBytes)
int	remove(SSTableReader reader)
void	replace(Collection<SSTableReader> removed, Collection<SSTableReader> added)
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

create

public static LeveledManifest create(ColumnFamilyStore cfs,
 int maxSSTableSize,
 int fanoutSize,
 List<SSTableReader> sstables)

create

public static LeveledManifest create(ColumnFamilyStore cfs,
 int maxSSTableSize,
 int fanoutSize,
 Iterable<SSTableReader> sstables,
 SizeTieredCompactionStrategyOptions options)

addSSTables

public void addSSTables(Iterable<SSTableReader> readers)

replace

public void replace(Collection<SSTableReader> removed,
 Collection<SSTableReader> added)

maxBytesForLevel

public long maxBytesForLevel(int level,
 long maxSSTableSizeInBytes)

maxBytesForLevel

public static long maxBytesForLevel(int level,
 int levelFanoutSize,
 long maxSSTableSizeInBytes)

getCompactionCandidates

public LeveledManifest.CompactionCandidate getCompactionCandidates()

Returns:

highest-priority sstables to compact, and level to compact them to If no compactions are necessary, will return null

getLevelSize

public int getLevelSize(int i)

getAllLevelSize

public int[] getAllLevelSize()

getAllLevelSizeBytes

public long[] getAllLevelSizeBytes()

remove

public int remove(SSTableReader reader)

getSSTables

public Set<SSTableReader> getSSTables()

getSStablesPerLevelSnapshot

public Set<SSTableReader>[] getSStablesPerLevelSnapshot()

toString

public String toString()

Overrides:

toString in class Object

getLevelCount

public int getLevelCount()

getEstimatedTasks

public int getEstimatedTasks()

getNextLevel

public int getNextLevel(Collection<SSTableReader> sstables)