|
|||||||||
| 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.ConcurrentUpdateSolrServer
public class ConcurrentUpdateSolrServer
ConcurrentUpdateSolrServer buffers all added documents and writes
them into open HTTP connections. This class is thread safe.
Params from UpdateRequest are converted to http request
parameters. When params change between UpdateRequests a new HTTP
request is started.
Although any SolrServer request can be made with this implementation, it is
only recommended to use ConcurrentUpdateSolrServer with /update
requests. The class HttpSolrServer is better suited for the
query interface.
| Constructor Summary | |
|---|---|
ConcurrentUpdateSolrServer(String solrServerUrl,
org.apache.http.client.HttpClient client,
int queueSize,
int threadCount)
Uses the supplied HttpClient to send documents to the Solr server, the HttpClient should be instantiated using a ThreadSafeClientConnManager. |
|
ConcurrentUpdateSolrServer(String solrServerUrl,
int queueSize,
int threadCount)
Uses an internal ThreadSafeClientConnManager to manage http connections. |
|
| Method Summary | |
|---|---|
void |
blockUntilFinished()
|
void |
handleError(Throwable ex)
|
NamedList<Object> |
request(SolrRequest request)
SolrServer implementations need to implement how a request is actually processed |
void |
setParser(ResponseParser responseParser)
|
void |
setRequestWriter(RequestWriter requestWriter)
|
void |
shutdown()
Release allocated resources. |
void |
shutdownNow()
|
| 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 ConcurrentUpdateSolrServer(String solrServerUrl,
int queueSize,
int threadCount)
solrServerUrl - The Solr server URLqueueSize - The buffer size before the documents are sent to the serverthreadCount - The number of background threads used to empty the queue
public ConcurrentUpdateSolrServer(String solrServerUrl,
org.apache.http.client.HttpClient client,
int queueSize,
int threadCount)
| Method Detail |
|---|
public NamedList<Object> request(SolrRequest request)
throws SolrServerException,
IOException
SolrServer
request in class SolrServerSolrServerException
IOExceptionpublic void blockUntilFinished()
public void handleError(Throwable ex)
public void shutdown()
SolrServer
shutdown in class SolrServerpublic void shutdownNow()
public void setParser(ResponseParser responseParser)
public void setRequestWriter(RequestWriter requestWriter)
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||