Class WatermarkCountEvictionPolicy<T>

java.lang.Object
org.apache.storm.windowing.WatermarkCountEvictionPolicy<T>
Type Parameters:
T - the type of event tracked by this policy.
All Implemented Interfaces:
EvictionPolicy<T,Pair<Long,Long>>

public class WatermarkCountEvictionPolicy<T> extends Object implements EvictionPolicy<T,Pair<Long,Long>>
An eviction policy that tracks count based on watermark ts and evicts events up to the watermark based on a threshold count.