Uses of Interface
org.apache.storm.windowing.TriggerPolicy

Packages that use TriggerPolicy

Package	Description
org.apache.storm.trident.windowing.strategy
org.apache.storm.windowing

Uses of TriggerPolicy in org.apache.storm.trident.windowing.strategy

Methods in org.apache.storm.trident.windowing.strategy that return TriggerPolicy

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

Uses of TriggerPolicy in org.apache.storm.windowing

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

Modifier and Type	Class and Description
class	CountTriggerPolicy<T> A trigger that tracks event counts and calls back TriggerHandler.onTrigger() when the count threshold is hit.
class	TimeTriggerPolicy<T> Invokes TriggerHandler.onTrigger() after the duration.
class	WatermarkCountTriggerPolicy<T> A trigger policy that tracks event counts and sets the context for eviction policy to evict based on latest watermark time.
class	WatermarkTimeTriggerPolicy<T> Handles watermark events and triggers TriggerHandler.onTrigger() for each window interval that has events to be processed up to the watermark ts.

Methods in org.apache.storm.windowing with parameters of type TriggerPolicy

Modifier and Type	Method and Description
void	WindowManager.setTriggerPolicy(TriggerPolicy<T> triggerPolicy)