Uses of Interface
org.apache.storm.windowing.TriggerHandler
-
Packages that use TriggerHandler Package Description org.apache.storm.trident.windowing.strategy org.apache.storm.windowing -
-
Uses of TriggerHandler in org.apache.storm.trident.windowing.strategy
Methods in org.apache.storm.trident.windowing.strategy with parameters of type TriggerHandler Modifier and Type Method Description TriggerPolicy<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
Classes in org.apache.storm.windowing that implement TriggerHandler Modifier and Type Class Description class
StatefulWindowManager<T>
Window manager that handles windows with state persistence.class
WindowManager<T>
Tracks a window of events and firesWindowLifecycleListener
callbacks on expiry of events or activation of the window due toTriggerPolicy
.Constructors in org.apache.storm.windowing with parameters of type TriggerHandler Constructor Description CountTriggerPolicy(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)
-