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.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.cloud.DistributedMap

DistributedMap.LatchChildWatcher, DistributedMap.MapEvent

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	log

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

DEFAULT_TIMEOUT, dir, prefix, response_prefix, zookeeper

Constructor Summary

Constructors

Constructor and Description
SizeLimitedDistributedMap(SolrZkClient zookeeper, String dir, List<org.apache.zookeeper.data.ACL> acl, int maxSize)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	put(String trackingId, byte[] data)

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

clear, contains, createData, get, put, remove, size

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.slf4j.Logger log

Constructor Detail

SizeLimitedDistributedMap

public SizeLimitedDistributedMap(SolrZkClient zookeeper,
                         String dir,
                         List<org.apache.zookeeper.data.ACL> acl,
                         int maxSize)

Method Detail

put

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

Overrides:

put in class DistributedMap

Throws:

org.apache.zookeeper.KeeperException

InterruptedException