Class SlidingCountWindowStrategy<T>
java.lang.Object
org.apache.storm.trident.windowing.strategy.BaseWindowStrategy<T>
org.apache.storm.trident.windowing.strategy.SlidingCountWindowStrategy<T>
- All Implemented Interfaces:
WindowStrategy<T>
This class represents sliding window strategy based on the sliding window count and sliding interval count 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 a count of given window length.TriggerPolicy<T,
?> getTriggerPolicy
(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every count of given sliding window.
-
Constructor Details
-
SlidingCountWindowStrategy
-
-
Method Details
-
getTriggerPolicy
public TriggerPolicy<T,?> getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every count of given sliding window. -
getEvictionPolicy
Returns anEvictionPolicy
instance which evicts elements after a count of given window length.
-