Class SlidingDurationWindowStrategy<T>
java.lang.Object
org.apache.storm.trident.windowing.strategy.BaseWindowStrategy<T>
org.apache.storm.trident.windowing.strategy.SlidingDurationWindowStrategy<T>
- All Implemented Interfaces:
WindowStrategy<T>
This class represents sliding window strategy based on the sliding window duration and sliding interval from the given
slidingCountWindow
configuration.-
Field Summary
Fields inherited from class org.apache.storm.trident.windowing.strategy.BaseWindowStrategy
windowConfig
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionEvictionPolicy<T,
?> Returns anEvictionPolicy
instance which evicts elements after window duration is reached.TriggerPolicy<T,
?> getTriggerPolicy
(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every configured sliding window duration.
-
Constructor Details
-
SlidingDurationWindowStrategy
-
-
Method Details
-
getTriggerPolicy
public TriggerPolicy<T,?> getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every configured sliding window duration. -
getEvictionPolicy
Returns anEvictionPolicy
instance which evicts elements after window duration is reached.
-