org.apache.solr.cloud

Class DistributedMap

java.lang.Object

org.apache.solr.cloud.DistributedMap

public class DistributedMap
extends Object

A distributed map. This supports basic map functions e.g. get, put, contains for interaction with zk which don't have to be ordered i.e. DistributedQueue.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DistributedMap.MapEvent

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	clear() Helper method to clear all child nodes for a parent node.
boolean	contains(String trackingId)
DistributedMap.MapEvent	get(String trackingId)
boolean	put(String trackingId, byte[] data)
DistributedMap.MapEvent	put(String trackingId, byte[] data, long timeout) Offer the data and wait for the response
void	remove(String trackingId)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedMap

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

Method Detail

put

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

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

put

public DistributedMap.MapEvent put(String trackingId,
                          byte[] data,
                          long timeout)
                            throws org.apache.zookeeper.KeeperException,
                                   InterruptedException

Offer the data and wait for the response

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

get

public DistributedMap.MapEvent get(String trackingId)
                            throws org.apache.zookeeper.KeeperException,
                                   InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

contains

public boolean contains(String trackingId)
                 throws org.apache.zookeeper.KeeperException,
                        InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

size

public int size()
         throws org.apache.zookeeper.KeeperException,
                InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

remove

public void remove(String trackingId)
            throws org.apache.zookeeper.KeeperException,
                   InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

clear

public void clear()
           throws org.apache.zookeeper.KeeperException,
                  InterruptedException

Helper method to clear all child nodes for a parent node.

Throws:

org.apache.zookeeper.KeeperException

InterruptedException