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 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,?>	TumblingCountWindowStrategy.getEvictionPolicy()	Returns an EvictionPolicy instance which evicts elements after a count of given window length.
EvictionPolicy<T,?>	TumblingDurationWindowStrategy.getEvictionPolicy()	Returns an EvictionPolicy instance which evicts elements after given window duration.
EvictionPolicy<T,?>	WindowStrategy.getEvictionPolicy()	Returns an EvictionPolicy instance 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 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,?>	TumblingCountWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)	Returns a TriggerPolicy which triggers for every count of given sliding window.
TriggerPolicy<T,?>	TumblingDurationWindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)	Returns a TriggerPolicy which triggers for every given sliding duration.
TriggerPolicy<T,?>	WindowStrategy.getTriggerPolicy(TriggerHandler triggerHandler, EvictionPolicy<T,?> evictionPolicy)	Returns a TriggerPolicy by creating with triggerHandler and evictionPolicy with 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
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.

Fields in org.apache.storm.windowing declared as EvictionPolicy

Modifier and Type	Field	Description
protected EvictionPolicy<T,?>	WindowManager.evictionPolicy

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

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

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

Modifier	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)