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 oldest maxSize / 10 items are evicted on the next put(String, byte[]) invocation.

Field Summary

Fields inherited from class org.apache.solr.cloud.DistributedMap

dir, PREFIX, zookeeper

Constructor Summary

Constructors

Constructor	Description
SizeLimitedDistributedMap(org.apache.solr.common.cloud.SolrZkClient zookeeper, String dir, int maxSize)
SizeLimitedDistributedMap(org.apache.solr.common.cloud.SolrZkClient zookeeper, String dir, int maxSize, org.apache.solr.cloud.SizeLimitedDistributedMap.OnOverflowObserver onOverflowObserver)

Method Summary

Modifier and Type	Method	Description
void	put(String trackingId, byte[] data)
boolean	putIfAbsent(String trackingId, byte[] data)	Puts an element in the map only if there isn't one with the same trackingId already

Methods inherited from class org.apache.solr.cloud.DistributedMap

clear, contains, get, keys, remove, size

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SizeLimitedDistributedMap

public SizeLimitedDistributedMap(org.apache.solr.common.cloud.SolrZkClient zookeeper,
                                 String dir,
                                 int maxSize)

SizeLimitedDistributedMap

public SizeLimitedDistributedMap(org.apache.solr.common.cloud.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 class DistributedMap

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

putIfAbsent

public boolean putIfAbsent(String trackingId,
                           byte[] data)
                    throws org.apache.zookeeper.KeeperException,
                           InterruptedException

Description copied from class: DistributedMap

Puts an element in the map only if there isn't one with the same trackingId already

Overrides:

putIfAbsent in class DistributedMap

Returns:

True if the element was added. False if it wasn't (because the key already exists)

Throws:

org.apache.zookeeper.KeeperException

InterruptedException