Package org.apache.storm.windowing
Class DefaultEvictionContext
java.lang.Object
org.apache.storm.windowing.DefaultEvictionContext
- All Implemented Interfaces:
- EvictionContext
- 
Constructor SummaryConstructorsConstructorDescriptionDefaultEvictionContext(Long referenceTime) DefaultEvictionContext(Long referenceTime, Long currentCount) DefaultEvictionContext(Long referenceTime, Long currentCount, Long slidingCount) DefaultEvictionContext(Long referenceTime, Long currentCount, Long slidingCount, Long slidingInterval) 
- 
Method SummaryModifier and TypeMethodDescriptionReturns the current count of events in the queue up to the reference time based on which count based evictions can be performed.Returns the reference time that the eviction policy could use to evict the events.Returns the sliding count for count based windows.Returns the sliding interval for time based windows.
- 
Constructor Details- 
DefaultEvictionContext
- 
DefaultEvictionContext
- 
DefaultEvictionContext
- 
DefaultEvictionContext
 
- 
- 
Method Details- 
getReferenceTimeDescription copied from interface:EvictionContextReturns 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:
- getReferenceTimein interface- EvictionContext
- Returns:
- the reference time in millis
 
- 
getCurrentCountDescription copied from interface:EvictionContextReturns the current count of events in the queue up to the reference time based on which count based evictions can be performed.- Specified by:
- getCurrentCountin interface- EvictionContext
- Returns:
- the current count
 
- 
getSlidingCountDescription copied from interface:EvictionContextReturns the sliding count for count based windows.- Specified by:
- getSlidingCountin interface- EvictionContext
- Returns:
- the sliding count
 
- 
getSlidingIntervalDescription copied from interface:EvictionContextReturns the sliding interval for time based windows.- Specified by:
- getSlidingIntervalin interface- EvictionContext
- Returns:
- the sliding interval
 
 
-