Uses of Interface
org.apache.storm.windowing.EvictionPolicy
-
Uses of EvictionPolicy in org.apache.storm.trident.windowing.strategy
Modifier and TypeMethodDescriptionEvictionPolicy<T,
?> SlidingCountWindowStrategy.getEvictionPolicy()
Returns anEvictionPolicy
instance which evicts elements after a count of given window length.EvictionPolicy<T,
?> SlidingDurationWindowStrategy.getEvictionPolicy()
Returns anEvictionPolicy
instance which evicts elements after window duration is reached.EvictionPolicy<T,
?> TumblingCountWindowStrategy.getEvictionPolicy()
Returns anEvictionPolicy
instance which evicts elements after a count of given window length.EvictionPolicy<T,
?> TumblingDurationWindowStrategy.getEvictionPolicy()
Returns anEvictionPolicy
instance which evicts elements after given window duration.EvictionPolicy<T,
?> WindowStrategy.getEvictionPolicy()
Returns anEvictionPolicy
instance for this strategy with the given configuration.Modifier and TypeMethodDescriptionTriggerPolicy<T,
?> SlidingCountWindowStrategy.getTriggerPolicy
(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every count of given sliding window.TriggerPolicy<T,
?> SlidingDurationWindowStrategy.getTriggerPolicy
(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every configured sliding window duration.TriggerPolicy<T,
?> TumblingCountWindowStrategy.getTriggerPolicy
(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every count of given sliding window.TriggerPolicy<T,
?> TumblingDurationWindowStrategy.getTriggerPolicy
(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
which triggers for every given sliding duration.TriggerPolicy<T,
?> WindowStrategy.getTriggerPolicy
(TriggerHandler triggerHandler, EvictionPolicy<T, ?> evictionPolicy) Returns aTriggerPolicy
by creating withtriggerHandler
andevictionPolicy
with the given configuration. -
Uses of EvictionPolicy in org.apache.storm.windowing
Modifier and TypeClassDescriptionclass
An eviction policy that tracks event counts and can evict based on a threshold count.class
Eviction policy that evicts events based on time duration.class
An eviction policy that tracks count based on watermark ts and evicts events up to the watermark based on a threshold count.class
An eviction policy that evicts events based on time duration taking watermark time and event lag into account.Modifier and TypeMethodDescriptionvoid
WindowManager.setEvictionPolicy
(EvictionPolicy<T, ?> evictionPolicy) ModifierConstructorDescriptionCountTriggerPolicy
(int count, TriggerHandler handler, EvictionPolicy<T, ?> evictionPolicy) TimeTriggerPolicy
(long millis, TriggerHandler handler, EvictionPolicy<T, ?> evictionPolicy) WatermarkCountTriggerPolicy
(int count, TriggerHandler handler, EvictionPolicy<T, ?> evictionPolicy, WindowManager<T> windowManager) WatermarkTimeTriggerPolicy
(long slidingIntervalMs, TriggerHandler handler, EvictionPolicy<T, ?> evictionPolicy, WindowManager<T> windowManager)