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>
public final class SlidingDurationWindowStrategy<T> extends BaseWindowStrategy<T>
This class represents sliding window strategy based on the sliding window duration and sliding interval from the givenslidingCountWindowconfiguration.
-
-
Field Summary
-
Fields inherited from class org.apache.storm.trident.windowing.strategy.BaseWindowStrategy
windowConfig
-
-
Constructor Summary
Constructors Constructor Description SlidingDurationWindowStrategy(WindowConfig slidingDurationWindow)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description EvictionPolicy<T,?>getEvictionPolicy()Returns anEvictionPolicyinstance which evicts elements after window duration is reached.TriggerPolicy<T,?>getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)Returns aTriggerPolicywhich triggers for every configured sliding window duration.
-
-
-
Constructor Detail
-
SlidingDurationWindowStrategy
public SlidingDurationWindowStrategy(WindowConfig slidingDurationWindow)
-
-
Method Detail
-
getTriggerPolicy
public TriggerPolicy<T,?> getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)
Returns aTriggerPolicywhich triggers for every configured sliding window duration.
-
getEvictionPolicy
public EvictionPolicy<T,?> getEvictionPolicy()
Returns anEvictionPolicyinstance which evicts elements after window duration is reached.
-
-