Package org.apache.solr.common.cloud
Class SolrZooKeeper
- java.lang.Object
-
- org.apache.zookeeper.ZooKeeper
-
- org.apache.solr.common.cloud.SolrZooKeeper
-
- All Implemented Interfaces:
AutoCloseable
public class SolrZooKeeper extends org.apache.zookeeper.ZooKeeper
-
-
Constructor Summary
Constructors Constructor Description SolrZooKeeper(String connectString, int sessionTimeout, org.apache.zookeeper.Watcher watcher)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
closeCnxn()
org.apache.zookeeper.ClientCnxn
getConnection()
SocketAddress
getSocketAddress()
-
Methods inherited from class org.apache.zookeeper.ZooKeeper
addAuthInfo, addWatch, addWatch, addWatch, addWatch, close, create, create, create, create, create, create, delete, delete, exists, exists, exists, exists, getACL, getACL, getAllChildrenNumber, getAllChildrenNumber, getChildren, getChildren, getChildren, getChildren, getChildren, getChildren, getChildren, getChildren, getChildWatches, getClientConfig, getConfig, getConfig, getConfig, getConfig, getData, getData, getData, getData, getDataWatches, getEphemerals, getEphemerals, getEphemerals, getEphemerals, getExistWatches, getPersistentRecursiveWatches, getPersistentWatches, getSaslClient, getSessionId, getSessionPasswd, getSessionTimeout, getState, getTestable, multi, multi, multiInternal, multiInternal, register, removeAllWatches, removeAllWatches, removeWatches, removeWatches, setACL, setACL, setData, setData, sync, testableLocalSocketAddress, testableRemoteSocketAddress, testableWaitForShutdown, toString, transaction, updateServerList, whoAmI
-
-
-
-
Constructor Detail
-
SolrZooKeeper
public SolrZooKeeper(String connectString, int sessionTimeout, org.apache.zookeeper.Watcher watcher) throws IOException
- Throws:
IOException
-
-
Method Detail
-
getConnection
public org.apache.zookeeper.ClientCnxn getConnection()
-
getSocketAddress
public SocketAddress getSocketAddress()
-
closeCnxn
public void closeCnxn()
-
close
public void close() throws InterruptedException
- Specified by:
close
in interfaceAutoCloseable
- Overrides:
close
in classorg.apache.zookeeper.ZooKeeper
- Throws:
InterruptedException
-
-