Package org.apache.cassandra.db

Class DiskBoundaries

java.lang.Object

org.apache.cassandra.db.DiskBoundaries

public class DiskBoundaries
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
final List<Directories.DataDirectory>	directories
final com.google.common.collect.ImmutableList<PartitionPosition>	positions

Constructor Summary

Constructors

Constructor	Description
DiskBoundaries(ColumnFamilyStore cfs, Directories.DataDirectory[] directories, int diskVersion)
DiskBoundaries(ColumnFamilyStore cfs, Directories.DataDirectory[] directories, List<PartitionPosition> positions, long ringVersion, int diskVersion)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	getBoundariesFromSSTableDirectory(Descriptor descriptor)	Try to figure out location based on sstable directory
Directories.DataDirectory	getCorrectDiskForKey(DecoratedKey key)
Directories.DataDirectory	getCorrectDiskForSSTable(SSTableReader sstable)
int	getDiskIndex(SSTableReader sstable)
List<Directories.DataDirectory>	getDisksInBounds(DecoratedKey first, DecoratedKey last)
int	hashCode()
void	invalidate()
boolean	isEquivalentTo(DiskBoundaries oldBoundaries)
boolean	isInCorrectLocation(SSTableReader sstable, Directories.DataDirectory currentLocation)
boolean	isOutOfDate()	check if the given disk boundaries are out of date due not being set or to having too old diskVersion/ringVersion
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

directories

public final List<Directories.DataDirectory> directories

positions

public final com.google.common.collect.ImmutableList<PartitionPosition> positions

Constructor Details

DiskBoundaries

public DiskBoundaries(ColumnFamilyStore cfs,
 Directories.DataDirectory[] directories,
 int diskVersion)

DiskBoundaries

public DiskBoundaries(ColumnFamilyStore cfs,
 Directories.DataDirectory[] directories,
 List<PartitionPosition> positions,
 long ringVersion,
 int diskVersion)

Method Details

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

isOutOfDate

public boolean isOutOfDate()

check if the given disk boundaries are out of date due not being set or to having too old diskVersion/ringVersion

invalidate

public void invalidate()

getDiskIndex

public int getDiskIndex(SSTableReader sstable)

getBoundariesFromSSTableDirectory

public int getBoundariesFromSSTableDirectory(Descriptor descriptor)

Try to figure out location based on sstable directory

getCorrectDiskForSSTable

public Directories.DataDirectory getCorrectDiskForSSTable(SSTableReader sstable)

getCorrectDiskForKey

public Directories.DataDirectory getCorrectDiskForKey(DecoratedKey key)

isInCorrectLocation

public boolean isInCorrectLocation(SSTableReader sstable,
 Directories.DataDirectory currentLocation)

getDisksInBounds

public List<Directories.DataDirectory> getDisksInBounds(DecoratedKey first,
 DecoratedKey last)

isEquivalentTo

public boolean isEquivalentTo(DiskBoundaries oldBoundaries)