Package org.apache.solr.cloud
Class SizeLimitedDistributedMap
- java.lang.Object
-
- org.apache.solr.cloud.DistributedMap
-
- org.apache.solr.cloud.SizeLimitedDistributedMap
-
public class SizeLimitedDistributedMap extends DistributedMap
A size limited distributed map maintained in zk. Oldest znodes (as per modification time) are evicted as newer ones come in. When the map hits the specified maximum size, the oldestmaxSize / 10
items are evicted on the nextput(String, byte[])
invocation.
-
-
Field Summary
-
Fields inherited from class org.apache.solr.cloud.DistributedMap
dir, PREFIX, zookeeper
-
-
Constructor Summary
Constructors Constructor Description SizeLimitedDistributedMap(SolrZkClient zookeeper, String dir, int maxSize)
SizeLimitedDistributedMap(SolrZkClient zookeeper, String dir, int maxSize, org.apache.solr.cloud.SizeLimitedDistributedMap.OnOverflowObserver onOverflowObserver)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
put(String trackingId, byte[] data)
-
Methods inherited from class org.apache.solr.cloud.DistributedMap
clear, contains, get, keys, putIfAbsent, remove, size
-
-
-
-
Constructor Detail
-
SizeLimitedDistributedMap
public SizeLimitedDistributedMap(SolrZkClient zookeeper, String dir, int maxSize)
-
SizeLimitedDistributedMap
public SizeLimitedDistributedMap(SolrZkClient zookeeper, String dir, int maxSize, org.apache.solr.cloud.SizeLimitedDistributedMap.OnOverflowObserver onOverflowObserver)
-
-
Method Detail
-
put
public void put(String trackingId, byte[] data) throws org.apache.zookeeper.KeeperException, InterruptedException
- Overrides:
put
in classDistributedMap
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
-
-