Class TumblingDurationWindowStrategy<T>
java.lang.Object
org.apache.storm.trident.windowing.strategy.BaseWindowStrategy<T>
org.apache.storm.trident.windowing.strategy.TumblingDurationWindowStrategy<T>
- All Implemented Interfaces:
WindowStrategy<T>
This class represents tumbling window strategy based on the window duration from the given
slidingCountWindow
configuration. In
this strategy , window and sliding durations are equal.-
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 given window duration.TriggerPolicy<T,
?> getTriggerPolicy
(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every given sliding duration.
-
Constructor Details
-
TumblingDurationWindowStrategy
-
-
Method Details
-
getTriggerPolicy
public TriggerPolicy<T,?> getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every given sliding duration. -
getEvictionPolicy
Returns anEvictionPolicy
instance which evicts elements after given window duration.
-