Package akka.remote.artery.compress

Class TopHeavyHitters<T>

  • public final class TopHeavyHitters<T>
extends java.lang.Object
    Iterates over the current heavy hitters, order is not of significance. Not thread safe, accesses internal heap directly (to avoid copying of data). Access must be synchronised externally.

    • Constructor Summary

      Constructors 
      Constructor Description
      TopHeavyHitters​(int max, scala.reflect.ClassTag<T> classTag)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int capacity()  
      scala.collection.Iterator<T> iterator()
      Iterates over the current heavy hitters, order is not of significance.
      long lowestHitterWeight()
      Weight of lowest heavy hitter, if a new inserted item has a weight greater than this, it is a heavy hitter.
      int mask()  
      int max()  
      java.lang.String toDebugString()  
      java.lang.String toString()  
      boolean update​(T item, long count)
      Attempt adding item to heavy hitters set, if it does not fit in the top yet, it will be dropped and the method will return false.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • TopHeavyHitters

        public TopHeavyHitters​(int max,
                       scala.reflect.ClassTag<T> classTag)

    • Method Detail

      • max

        public int max()

      • capacity

        public int capacity()

      • mask

        public int mask()

      • iterator

        public scala.collection.Iterator<T> iterator()
        Iterates over the current heavy hitters, order is not of significance. Not thread safe, accesses internal heap directly (to avoid copying of data). Access must be synchronised externally.
        Returns:
        (undocumented)

      • toDebugString

        public java.lang.String toDebugString()

      • update

        public boolean update​(T item,
                      long count)
        Attempt adding item to heavy hitters set, if it does not fit in the top yet, it will be dropped and the method will return false.

        WARNING: It is only allowed to *increase* the weight of existing elements, decreasing is disallowed.

        Parameters:
        item - (undocumented)
        count - (undocumented)
        Returns:
        true if the added item has become a heavy hitter.

      • lowestHitterWeight

        public long lowestHitterWeight()
        Weight of lowest heavy hitter, if a new inserted item has a weight greater than this, it is a heavy hitter. This gets the index of the lowest heavy hitter from the top of the heap (lowestHitterIndex) if there is any and looks up its weight. If there is no entry in the table (lowestHitterIndex returns a negative index) this returns a zero weight.
        Returns:
        (undocumented)

      • toString

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