|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.solr.client.solrj.SolrServer
org.apache.solr.client.solrj.impl.CloudSolrServer
public class CloudSolrServer
SolrJ client class to communicate with SolrCloud.
Instances of this class communicate with Zookeeper to discover
Solr endpoints for SolrCloud collections, and then use the
LBHttpSolrServer
to issue requests.
Constructor Summary | |
---|---|
CloudSolrServer(String zkHost)
|
|
CloudSolrServer(String zkHost,
LBHttpSolrServer lbServer)
|
|
CloudSolrServer(String zkHost,
LBHttpSolrServer lbServer,
boolean updatesToLeaders)
|
Method Summary | |
---|---|
void |
connect()
Connect to the zookeeper ensemble. |
LBHttpSolrServer |
getLbServer()
|
ZkStateReader |
getZkStateReader()
|
NamedList<Object> |
request(SolrRequest request)
SolrServer implementations need to implement how a request is actually processed |
void |
setDefaultCollection(String collection)
Sets the default collection for request |
void |
setZkClientTimeout(int zkClientTimeout)
Set the timeout to the zookeeper ensemble in ms |
void |
setZkConnectTimeout(int zkConnectTimeout)
Set the connect timeout to the zookeeper ensemble in ms |
void |
shutdown()
Release allocated resources. |
Methods inherited from class org.apache.solr.client.solrj.SolrServer |
---|
add, add, add, add, addBean, addBean, addBeans, addBeans, commit, commit, commit, deleteById, deleteById, deleteById, deleteById, deleteByQuery, deleteByQuery, getBinder, optimize, optimize, optimize, ping, query, query, queryAndStreamResponse, rollback |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public CloudSolrServer(String zkHost) throws MalformedURLException
zkHost
- The client endpoint of the zookeeper quorum containing the cloud state,
in the form HOST:PORT.
MalformedURLException
public CloudSolrServer(String zkHost, LBHttpSolrServer lbServer)
zkHost
- The client endpoint of the zookeeper quorum containing the cloud state,
in the form HOST:PORT.lbServer
- LBHttpSolrServer instance for requests.public CloudSolrServer(String zkHost, LBHttpSolrServer lbServer, boolean updatesToLeaders)
zkHost
- The client endpoint of the zookeeper quorum containing the cloud state,
in the form HOST:PORT.lbServer
- LBHttpSolrServer instance for requests.updatesToLeaders
- sends updates only to leaders - defaults to trueMethod Detail |
---|
public ZkStateReader getZkStateReader()
public void setDefaultCollection(String collection)
public void setZkConnectTimeout(int zkConnectTimeout)
public void setZkClientTimeout(int zkClientTimeout)
public void connect()
public NamedList<Object> request(SolrRequest request) throws SolrServerException, IOException
SolrServer
request
in class SolrServer
SolrServerException
IOException
public void shutdown()
SolrServer
shutdown
in class SolrServer
public LBHttpSolrServer getLbServer()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |