Package org.apache.cassandra.metrics

Class TopPartitionTracker.TopHolder

java.lang.Object

org.apache.cassandra.metrics.TopPartitionTracker.TopHolder

Enclosing class:

TopPartitionTracker

public static class TopPartitionTracker.TopHolder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
final long	lastUpdate
final NavigableSet<TopPartitionTracker.TopPartition>	top

Method Summary

Modifier and Type	Method	Description
TopPartitionTracker.TopHolder	merge(TopPartitionTracker.TopHolder holder, Collection<Range<Token>> ownedRanges)	we merge any pre-existing top partitions on to the ones we just collected if they are outside of the range collected.
Map<String,Long>	toMap(TableMetadata metadata)
String	toString()
void	track(DecoratedKey key, long value)

Methods inherited from class java.lang.Object

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

Field Details

top

public final NavigableSet<TopPartitionTracker.TopPartition> top

lastUpdate

public final long lastUpdate

Method Details

track

public void track(DecoratedKey key,
 long value)

merge

public TopPartitionTracker.TopHolder merge(TopPartitionTracker.TopHolder holder,
 Collection<Range<Token>> ownedRanges)

we merge any pre-existing top partitions on to the ones we just collected if they are outside of the range collected. This means that if a large partition is deleted it will disappear from the top partitions

Parameters:

holder - the newly collected holder - this will get copied and any existing token outside of the collected ranges will get added to the copy

ownedRanges - the ranges this node owns - any existing token outside of these ranges will get dropped

toString

public String toString()

Overrides:

toString in class Object

toMap

public Map<String,Long> toMap(TableMetadata metadata)