Class SimpleWindowPartitionCache<K,V>

java.lang.Object
org.apache.storm.windowing.persistence.SimpleWindowPartitionCache<K,V>
All Implemented Interfaces:
WindowPartitionCache<K,V>

public class SimpleWindowPartitionCache<K,V> extends Object implements WindowPartitionCache<K,V>
A simple implementation that evicts the largest un-pinned entry from the cache. This works well for caching window partitions since the access pattern is mostly sequential scans.