org.apache.solr.client.solrj.impl
Class CloudSolrServer

java.lang.Object
  org.apache.solr.client.solrj.SolrServer
      org.apache.solr.client.solrj.impl.CloudSolrServer

All Implemented Interfaces:

Serializable

public class CloudSolrServer
extends SolrServer

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.

See Also:

Serialized Form

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

CloudSolrServer

public CloudSolrServer(String zkHost)
                throws MalformedURLException

Parameters:

zkHost - The client endpoint of the zookeeper quorum containing the cloud state, in the form HOST:PORT.

Throws:

MalformedURLException

CloudSolrServer

public CloudSolrServer(String zkHost,
                       LBHttpSolrServer lbServer)

Parameters:

zkHost - The client endpoint of the zookeeper quorum containing the cloud state, in the form HOST:PORT.

lbServer - LBHttpSolrServer instance for requests.

CloudSolrServer

public CloudSolrServer(String zkHost,
                       LBHttpSolrServer lbServer,
                       boolean updatesToLeaders)

Parameters:

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 true

Method Detail

getZkStateReader

public ZkStateReader getZkStateReader()

setDefaultCollection

public void setDefaultCollection(String collection)

Sets the default collection for request

setZkConnectTimeout

public void setZkConnectTimeout(int zkConnectTimeout)

Set the connect timeout to the zookeeper ensemble in ms

setZkClientTimeout

public void setZkClientTimeout(int zkClientTimeout)

Set the timeout to the zookeeper ensemble in ms

connect

public void connect()

Connect to the zookeeper ensemble. This is an optional method that may be used to force a connect before any other requests are sent.

request

public NamedList<Object> request(SolrRequest request)
                          throws SolrServerException,
                                 IOException

Description copied from class: SolrServer

SolrServer implementations need to implement how a request is actually processed

Specified by:

request in class SolrServer

Throws:

SolrServerException

IOException

shutdown

public void shutdown()

Description copied from class: SolrServer

Release allocated resources.

Specified by:

shutdown in class SolrServer

getLbServer

public LBHttpSolrServer getLbServer()