Uses of Interface
org.apache.storm.windowing.TriggerHandler
-
Uses of TriggerHandler in org.apache.storm.trident.windowing.strategy
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 TriggerHandler in org.apache.storm.windowing
Modifier and TypeClassDescriptionclass
Window manager that handles windows with state persistence.class
Tracks a window of events and firesWindowLifecycleListener
callbacks on expiry of events or activation of the window due toTriggerPolicy
.ModifierConstructorDescriptionCountTriggerPolicy
(int count, TriggerHandler handler, EvictionPolicy<T, ?> evictionPolicy) TimeTriggerPolicy
(long millis, TriggerHandler handler) 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)