Package org.apache.cassandra.metrics

Class TopPartitionTracker

java.lang.Object

org.apache.cassandra.metrics.TopPartitionTracker

All Implemented Interfaces:

Closeable, AutoCloseable

public class TopPartitionTracker
extends Object
implements Closeable

Tracks top partitions, currently by size and by tombstone count Collects during full and preview (-vd) repair since then we read the full partition Note that since we can run sub range repair there might be windows where the top partitions are not correct - for example, assume we track the top 2 partitions for this node: tokens with size: (a, 100); (b, 40); (c, 10); (d, 100); (e, 50); (f, 10) - top2: a, d now a is deleted and we run a repair for keys [a, c] - top2: b, d and when we repair [d, f] - top2: d, e

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TopPartitionTracker.Collector
static class	TopPartitionTracker.StoredTopPartitions
static class	TopPartitionTracker.TombstoneCounter
static class	TopPartitionTracker.TopHolder
static class	TopPartitionTracker.TopPartition

Constructor Summary

Constructors

Constructor	Description
TopPartitionTracker(TableMetadata metadata)

Method Summary

Modifier and Type	Method	Description
void	close()
Map<String,Long>	getTopSizePartitionMap()
Map<String,Long>	getTopTombstonePartitionMap()
void	merge(TopPartitionTracker.Collector collector)
void	save()
TopPartitionTracker.TopHolder	topSizes()
TopPartitionTracker.TopHolder	topTombstones()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TopPartitionTracker

public TopPartitionTracker(TableMetadata metadata)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

save

public void save()

merge

public void merge(TopPartitionTracker.Collector collector)

toString

public String toString()

Overrides:

toString in class Object

getTopTombstonePartitionMap

public Map<String,Long> getTopTombstonePartitionMap()

getTopSizePartitionMap

public Map<String,Long> getTopSizePartitionMap()

topSizes

public TopPartitionTracker.TopHolder topSizes()

topTombstones

public TopPartitionTracker.TopHolder topTombstones()