org.apache.solr.cloud

Class DistributedMap

java.lang.Object

org.apache.solr.cloud.DistributedMap

Direct Known Subclasses:

SizeLimitedDistributedMap

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
protected class	DistributedMap.LatchChildWatcher
static class	DistributedMap.MapEvent

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	DEFAULT_TIMEOUT
protected String	dir
protected String	prefix
protected String	response_prefix
protected SolrZkClient	zookeeper

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)
protected String	createData(String path, byte[] data, org.apache.zookeeper.CreateMode mode) Inserts data into zookeeper.
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

Field Detail

DEFAULT_TIMEOUT

protected static long DEFAULT_TIMEOUT

dir

protected final String dir

zookeeper

protected SolrZkClient zookeeper

prefix

protected final String prefix

See Also:

Constant Field Values

response_prefix

protected final String response_prefix

See Also:

Constant Field Values

Constructor Detail

DistributedMap

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

Method Detail

createData

protected String createData(String path,
                byte[] data,
                org.apache.zookeeper.CreateMode mode)
                     throws org.apache.zookeeper.KeeperException,
                            InterruptedException

Inserts data into zookeeper.

Returns:

true if data was successfully added

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

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