Package org.apache.cassandra.db.compaction

Class ShardManagerDiskAware.BoundaryTrackerDiskAware

java.lang.Object

org.apache.cassandra.db.compaction.ShardManagerDiskAware.BoundaryTrackerDiskAware

All Implemented Interfaces:

ShardTracker

Enclosing class:

ShardManagerDiskAware

public class ShardManagerDiskAware.BoundaryTrackerDiskAware
extends Object
implements ShardTracker

Constructor Summary

Constructors

Constructor	Description
BoundaryTrackerDiskAware(int countPerDisk)

Method Summary

Modifier and Type	Method	Description
boolean	advanceTo(Token nextToken)	Advance to the given token (e.g.
int	count()
double	fractionInShard(Range<Token> targetSpan)	Returns the fraction of the given token range's coverage that falls within this shard.
double	rangeSpanned(PartitionPosition first, PartitionPosition last)
Token	shardEnd()
int	shardIndex()
Range<Token>	shardSpan()
double	shardSpanSize()
Token	shardStart()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.db.compaction.ShardTracker

applyTokenSpaceCoverage, shardAdjustedKeyCount

Constructor Details

BoundaryTrackerDiskAware

public BoundaryTrackerDiskAware(int countPerDisk)

Method Details

shardStart

public Token shardStart()

Specified by:

shardStart in interface ShardTracker

shardEnd

public Token shardEnd()

Specified by:

shardEnd in interface ShardTracker

shardSpan

public Range<Token> shardSpan()

Specified by:

shardSpan in interface ShardTracker

shardSpanSize

public double shardSpanSize()

Specified by:

shardSpanSize in interface ShardTracker

advanceTo

public boolean advanceTo(Token nextToken)

Advance to the given token (e.g. before writing a key). Returns true if this resulted in advancing to a new shard, and false otherwise.

Specified by:

advanceTo in interface ShardTracker

count

public int count()

Specified by:

count in interface ShardTracker

fractionInShard

public double fractionInShard(Range<Token> targetSpan)

Returns the fraction of the given token range's coverage that falls within this shard. E.g. if the span covers two shards exactly and the current shard is one of them, it will return 0.5.

Specified by:

fractionInShard in interface ShardTracker

rangeSpanned

public double rangeSpanned(PartitionPosition first,
 PartitionPosition last)

Specified by:

rangeSpanned in interface ShardTracker

shardIndex

public int shardIndex()

Specified by:

shardIndex in interface ShardTracker