Uses of Interface
org.apache.storm.windowing.TriggerPolicy
-
Uses of TriggerPolicy in org.apache.storm.trident.windowing.strategy
Modifier and TypeMethodDescriptionTriggerPolicy<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
Modifier and TypeClassDescriptionclass
A trigger that tracks event counts and calls backTriggerHandler.onTrigger()
when the count threshold is hit.class
InvokesTriggerHandler.onTrigger()
after the duration.class
A trigger policy that tracks event counts and sets the context for eviction policy to evict based on latest watermark time.class
Handles watermark events and triggersTriggerHandler.onTrigger()
for each window interval that has events to be processed up to the watermark ts.Modifier and TypeMethodDescriptionvoid
WindowManager.setTriggerPolicy
(TriggerPolicy<T, ?> triggerPolicy)