org.apache.storm.windowing

Interface EvictionContext

All Known Implementing Classes:

DefaultEvictionContext

public interface EvictionContext

Context information that can be used by the eviction policy

Method Summary

Modifier and Type	Method and Description
java.lang.Long	getCurrentCount() Returns the current count of events in the queue up to the reference time based on which count based evictions can be performed.
java.lang.Long	getReferenceTime() Returns the reference time that the eviction policy could use to evict the events.
java.lang.Long	getSlidingCount() Returns the sliding count for count based windows
java.lang.Long	getSlidingInterval() Returns the sliding interval for time based windows

Method Detail

getReferenceTime

java.lang.Long getReferenceTime()

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.

Returns:

the reference time in millis

getSlidingCount

java.lang.Long getSlidingCount()

Returns the sliding count for count based windows

Returns:

the sliding count

getSlidingInterval

java.lang.Long getSlidingInterval()

Returns the sliding interval for time based windows

Returns:

the sliding interval

getCurrentCount

java.lang.Long getCurrentCount()

Returns the current count of events in the queue up to the reference time based on which count based evictions can be performed.

Returns:

the current count