Package org.apache.cassandra.metrics

Class TopPartitionTracker

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable
    public class TopPartitionTracker
extends java.lang.Object
implements java.io.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

    • Constructor Detail

      • TopPartitionTracker

        public TopPartitionTracker​(TableMetadata metadata)

    • Method Detail

      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable

      • save

        public void save()

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object

      • getTopTombstonePartitionMap

        public java.util.Map<java.lang.String,​java.lang.Long> getTopTombstonePartitionMap()

      • getTopSizePartitionMap

        public java.util.Map<java.lang.String,​java.lang.Long> getTopSizePartitionMap()