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 and Description
EvictionPolicy<T>	WindowStrategy.getEvictionPolicy() Returns an EvictionPolicy instance for this strategy with the given configuration.
EvictionPolicy<T>	TumblingDurationWindowStrategy.getEvictionPolicy() Returns an EvictionPolicy instance which evicts elements after given window duration.
EvictionPolicy<T>	TumblingCountWindowStrategy.getEvictionPolicy() Returns an EvictionPolicy instance which evicts elements after a count of given window length.
EvictionPolicy<T>	SlidingDurationWindowStrategy.getEvictionPolicy() Returns an EvictionPolicy instance which evicts elements after window duration is reached.
EvictionPolicy<T>	SlidingCountWindowStrategy.getEvictionPolicy() Returns an EvictionPolicy instance which evicts elements after a count of given window length.

Methods in org.apache.storm.trident.windowing.strategy with parameters of type EvictionPolicy

Modifier and Type	Method and Description
TriggerPolicy<T>	WindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T> evictionPolicy) Returns a TriggerPolicy by creating with triggerHandler and evictionPolicy with the given configuration.
TriggerPolicy<T>	TumblingDurationWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T> evictionPolicy) Returns a TriggerPolicy which triggers for every given sliding duration.
TriggerPolicy<T>	TumblingCountWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T> evictionPolicy) Returns a TriggerPolicy which triggers for every count of given sliding window.
TriggerPolicy<T>	SlidingDurationWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T> evictionPolicy) Returns a TriggerPolicy which triggers for every configured sliding window duration.
TriggerPolicy<T>	SlidingCountWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T> evictionPolicy) Returns a TriggerPolicy which triggers for every count of given sliding window.

Uses of EvictionPolicy in org.apache.storm.windowing

Classes in org.apache.storm.windowing that implement EvictionPolicy

Modifier and Type	Class and Description
class	CountEvictionPolicy<T> An eviction policy that tracks event counts and can evict based on a threshold count.
class	TimeEvictionPolicy<T> Eviction policy that evicts events based on time duration.
class	WatermarkCountEvictionPolicy<T> An eviction policy that tracks count based on watermark ts and evicts events up to the watermark based on a threshold count.
class	WatermarkTimeEvictionPolicy<T> An eviction policy that evicts events based on time duration taking watermark time and event lag into account.

Methods in org.apache.storm.windowing with parameters of type EvictionPolicy

Modifier and Type	Method and Description
void	WindowManager.setEvictionPolicy(EvictionPolicy<T> evictionPolicy)

Constructors in org.apache.storm.windowing with parameters of type EvictionPolicy

Constructor and 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)