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 aTriggerPolicywhich triggers for every count of given sliding window.TriggerPolicy<T,?>SlidingDurationWindowStrategy. getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)Returns aTriggerPolicywhich triggers for every configured sliding window duration.TriggerPolicy<T,?>TumblingCountWindowStrategy. getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)Returns aTriggerPolicywhich triggers for every count of given sliding window.TriggerPolicy<T,?>TumblingDurationWindowStrategy. getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)Returns aTriggerPolicywhich triggers for every given sliding duration.TriggerPolicy<T,?>WindowStrategy. getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)Returns aTriggerPolicyby creating withtriggerHandlerandevictionPolicywith 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 classStatefulWindowManager<T>Window manager that handles windows with state persistence.classWindowManager<T>Tracks a window of events and firesWindowLifecycleListenercallbacks 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)
-