Uses of Interface
org.apache.storm.windowing.EvictionPolicy
Packages that use EvictionPolicy
-
Uses of EvictionPolicy in org.apache.storm.trident.windowing.strategy
Methods in org.apache.storm.trident.windowing.strategy that return EvictionPolicyModifier and TypeMethodDescriptionEvictionPolicy<T,?> SlidingCountWindowStrategy.getEvictionPolicy()Returns anEvictionPolicyinstance which evicts elements after a count of given window length.EvictionPolicy<T,?> SlidingDurationWindowStrategy.getEvictionPolicy()Returns anEvictionPolicyinstance which evicts elements after window duration is reached.EvictionPolicy<T,?> TumblingCountWindowStrategy.getEvictionPolicy()Returns anEvictionPolicyinstance which evicts elements after a count of given window length.EvictionPolicy<T,?> TumblingDurationWindowStrategy.getEvictionPolicy()Returns anEvictionPolicyinstance which evicts elements after given window duration.EvictionPolicy<T,?> WindowStrategy.getEvictionPolicy()Returns anEvictionPolicyinstance for this strategy with the given configuration.Methods in org.apache.storm.trident.windowing.strategy with parameters of type EvictionPolicyModifier 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 EvictionPolicy in org.apache.storm.windowing
Classes in org.apache.storm.windowing that implement EvictionPolicyModifier and TypeClassDescriptionclassAn eviction policy that tracks event counts and can evict based on a threshold count.classEviction policy that evicts events based on time duration.classAn eviction policy that tracks count based on watermark ts and evicts events up to the watermark based on a threshold count.classAn eviction policy that evicts events based on time duration taking watermark time and event lag into account.Fields in org.apache.storm.windowing declared as EvictionPolicyMethods in org.apache.storm.windowing with parameters of type EvictionPolicyModifier and TypeMethodDescriptionvoidWindowManager.setEvictionPolicy(EvictionPolicy<T, ?> evictionPolicy) Constructors in org.apache.storm.windowing with parameters of type EvictionPolicyModifierConstructorDescriptionCountTriggerPolicy(int count, TriggerHandler handler, EvictionPolicy<T, ?> evictionPolicy) 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)