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 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 TriggerPolicy in org.apache.storm.windowing
Classes in org.apache.storm.windowing that implement TriggerPolicy Modifier and Type Class Description class
CountTriggerPolicy<T>
A trigger that tracks event counts and calls backTriggerHandler.onTrigger()
when the count threshold is hit.class
TimeTriggerPolicy<T>
InvokesTriggerHandler.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 triggersTriggerHandler.onTrigger()
for each window interval that has events to be processed up to the watermark ts.Fields in org.apache.storm.windowing declared as TriggerPolicy Modifier and Type Field Description protected TriggerPolicy<T,?>
WindowManager. triggerPolicy
Methods in org.apache.storm.windowing with parameters of type TriggerPolicy Modifier and Type Method Description void
WindowManager. setTriggerPolicy(TriggerPolicy<T,?> triggerPolicy)
-