Class DefaultEvictionContext

java.lang.Object
org.apache.storm.windowing.DefaultEvictionContext
All Implemented Interfaces:
EvictionContext

public class DefaultEvictionContext extends Object implements EvictionContext
  • Constructor Details

    • DefaultEvictionContext

      public DefaultEvictionContext(Long referenceTime)
    • DefaultEvictionContext

      public DefaultEvictionContext(Long referenceTime, Long currentCount)
    • DefaultEvictionContext

      public DefaultEvictionContext(Long referenceTime, Long currentCount, Long slidingCount)
    • DefaultEvictionContext

      public DefaultEvictionContext(Long referenceTime, Long currentCount, Long slidingCount, Long slidingInterval)
  • Method Details

    • getReferenceTime

      public Long getReferenceTime()
      Description copied from interface: EvictionContext
      Returns the reference time that the eviction policy could use to evict the events. In the case of event time processing, this would be the watermark time.
      Specified by:
      getReferenceTime in interface EvictionContext
      Returns:
      the reference time in millis
    • getCurrentCount

      public Long getCurrentCount()
      Description copied from interface: EvictionContext
      Returns the current count of events in the queue up to the reference time based on which count based evictions can be performed.
      Specified by:
      getCurrentCount in interface EvictionContext
      Returns:
      the current count
    • getSlidingCount

      public Long getSlidingCount()
      Description copied from interface: EvictionContext
      Returns the sliding count for count based windows.
      Specified by:
      getSlidingCount in interface EvictionContext
      Returns:
      the sliding count
    • getSlidingInterval

      public Long getSlidingInterval()
      Description copied from interface: EvictionContext
      Returns the sliding interval for time based windows.
      Specified by:
      getSlidingInterval in interface EvictionContext
      Returns:
      the sliding interval