Uses of Interface
org.apache.storm.windowing.EvictionPolicy
-
Packages that use EvictionPolicy Package Description org.apache.storm.trident.windowing.strategy org.apache.storm.windowing -
-
Uses of EvictionPolicy in org.apache.storm.trident.windowing.strategy
Methods in org.apache.storm.trident.windowing.strategy that return EvictionPolicy Modifier and Type Method Description EvictionPolicy<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 EvictionPolicy Modifier and Type Method Description TriggerPolicy<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 EvictionPolicy Modifier and Type Class Description classCountEvictionPolicy<T>An eviction policy that tracks event counts and can evict based on a threshold count.classTimeEvictionPolicy<T>Eviction policy that evicts events based on time duration.classWatermarkCountEvictionPolicy<T>An eviction policy that tracks count based on watermark ts and evicts events up to the watermark based on a threshold count.classWatermarkTimeEvictionPolicy<T>An 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 EvictionPolicy Modifier and Type Field Description protected EvictionPolicy<T,?>WindowManager. evictionPolicyMethods in org.apache.storm.windowing with parameters of type EvictionPolicy Modifier and Type Method Description voidWindowManager. setEvictionPolicy(EvictionPolicy<T,?> evictionPolicy)Constructors in org.apache.storm.windowing with parameters of type EvictionPolicy Constructor Description CountTriggerPolicy(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)
-