Uses of Interface
org.apache.storm.windowing.TriggerPolicy
Packages that use TriggerPolicy
-
Uses of TriggerPolicy in org.apache.storm.trident.windowing.strategy
Methods in org.apache.storm.trident.windowing.strategy that return TriggerPolicyModifier and TypeMethodDescriptionTriggerPolicy<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 TriggerPolicy in org.apache.storm.windowing
Classes in org.apache.storm.windowing that implement TriggerPolicyModifier and TypeClassDescriptionclassA trigger that tracks event counts and calls backTriggerHandler.onTrigger()when the count threshold is hit.classInvokesTriggerHandler.onTrigger()after the duration.classA trigger policy that tracks event counts and sets the context for eviction policy to evict based on latest watermark time.classHandles 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 TriggerPolicyMethods in org.apache.storm.windowing with parameters of type TriggerPolicyModifier and TypeMethodDescriptionvoidWindowManager.setTriggerPolicy(TriggerPolicy<T, ?> triggerPolicy)