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 and Description
TriggerPolicy<T,?>	TumblingDurationWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy) Returns a TriggerPolicy which triggers for every given sliding duration.
TriggerPolicy<T,?>	WindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy) Returns a TriggerPolicy by creating with triggerHandler and evictionPolicy with the given configuration.
TriggerPolicy<T,?>	TumblingCountWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy) Returns a TriggerPolicy which triggers for every count of given sliding window.
TriggerPolicy<T,?>	SlidingCountWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy) Returns a TriggerPolicy which triggers for every count of given sliding window.
TriggerPolicy<T,?>	SlidingDurationWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy) Returns a TriggerPolicy which triggers for every configured sliding window duration.

Uses of TriggerHandler in org.apache.storm.windowing

Classes in org.apache.storm.windowing that implement TriggerHandler

Modifier and Type	Class and Description
class	StatefulWindowManager<T> Window manager that handles windows with state persistence.
class	WindowManager<T> Tracks a window of events and fires WindowLifecycleListener callbacks on expiry of events or activation of the window due to TriggerPolicy.

Constructors in org.apache.storm.windowing with parameters of type TriggerHandler

Constructor and 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)