Class ThresholdPolicyCount<T>

  • All Implemented Interfaces:
    ThresholdPolicy<T>

    public class ThresholdPolicyCount<T>
    extends java.lang.Object
    implements ThresholdPolicy<T>
    A threshold policy based on the number of tuples added.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      long getCount()
      Returns the current count of the number of items incremented in this policy.
      long getThreshold()
      Returns the threshold before the list is written to disk.
      void increment​(T item)
      Call this method each time to increment the policy's threshold count.
      boolean isThresholdExceeded()
      Determines whether or not the configured threshold has been exceeded for this policy.
      void reset()
      Reset the policy back to the initial state.
      java.lang.String toString()  
      • Methods inherited from class java.lang.Object

        equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • ThresholdPolicyCount

        public ThresholdPolicyCount​(long threshold)
    • Method Detail

      • increment

        public void increment​(T item)
        Description copied from interface: ThresholdPolicy
        Call this method each time to increment the policy's threshold count.
        Specified by:
        increment in interface ThresholdPolicy<T>
        Parameters:
        item - The item that was added.
      • isThresholdExceeded

        public boolean isThresholdExceeded()
        Description copied from interface: ThresholdPolicy
        Determines whether or not the configured threshold has been exceeded for this policy.
        Specified by:
        isThresholdExceeded in interface ThresholdPolicy<T>
        Returns:
        true if the threshold has been reached; false otherwise.
      • getThreshold

        public long getThreshold()
        Returns the threshold before the list is written to disk.
        Returns:
        The threshold point.
      • getCount

        public long getCount()
        Returns the current count of the number of items incremented in this policy.
        Returns:
        The item count.
      • toString

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