org.apache.solr.client.solrj.impl

Class ConcurrentUpdateSolrServer

java.lang.Object

org.apache.solr.client.solrj.SolrServer

org.apache.solr.client.solrj.impl.ConcurrentUpdateSolrServer

All Implemented Interfaces:

java.io.Serializable

public class ConcurrentUpdateSolrServer
extends SolrServer

ConcurrentUpdateSolrServer buffers all added documents and writes them into open HTTP connections. This class is thread safe. 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.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	ConcurrentUpdateSolrServer.Runner Opens a connection and sends everything...

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.util.concurrent.CountDownLatch	lock
(package private) static org.slf4j.Logger	log
(package private) java.util.concurrent.BlockingQueue<UpdateRequest>	queue
(package private) java.util.Queue<ConcurrentUpdateSolrServer.Runner>	runners
(package private) java.util.concurrent.ExecutorService	scheduler
private static long	serialVersionUID
private HttpSolrServer	server
(package private) int	threadCount
(package private) java.lang.String	updateUrl

Constructor Summary

Constructors

Constructor and Description
ConcurrentUpdateSolrServer(java.lang.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(java.lang.String solrServerUrl, int queueSize, int threadCount) Uses an internal ThreadSafeClientConnManager to manage http connections.

Method Summary

Modifier and Type	Method and Description
void	blockUntilFinished()
void	handleError(java.lang.Throwable ex)
NamedList<java.lang.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()
void	shutdownNow()

Methods inherited from class org.apache.solr.client.solrj.SolrServer

add, add, add, add, addBean, addBean, addBeans, addBeans, commit, commit, deleteById, deleteById, deleteById, deleteById, deleteByQuery, deleteByQuery, getBinder, optimize, optimize, optimize, ping, query, query, rollback

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

log

static final org.slf4j.Logger log

server

private HttpSolrServer server

queue

final java.util.concurrent.BlockingQueue<UpdateRequest> queue

scheduler

final java.util.concurrent.ExecutorService scheduler

updateUrl

final java.lang.String updateUrl

See Also:

Constant Field Values

runners

final java.util.Queue<ConcurrentUpdateSolrServer.Runner> runners

lock

volatile java.util.concurrent.CountDownLatch lock

threadCount

final int threadCount

Constructor Detail

ConcurrentUpdateSolrServer

public ConcurrentUpdateSolrServer(java.lang.String solrServerUrl,
                                  int queueSize,
                                  int threadCount)
                           throws java.net.MalformedURLException

Uses an internal ThreadSafeClientConnManager to manage http connections.

Parameters:

solrServerUrl - The Solr server URL

queueSize - The buffer size before the documents are sent to the server

threadCount - The number of background threads used to empty the queue

Throws:

java.net.MalformedURLException

ConcurrentUpdateSolrServer

public ConcurrentUpdateSolrServer(java.lang.String solrServerUrl,
                                  org.apache.http.client.HttpClient client,
                                  int queueSize,
                                  int threadCount)
                           throws java.net.MalformedURLException

Uses the supplied HttpClient to send documents to the Solr server, the HttpClient should be instantiated using a ThreadSafeClientConnManager.

Throws:

java.net.MalformedURLException

Method Detail

request

public NamedList<java.lang.Object> request(SolrRequest request)
                                    throws SolrServerException,
                                           java.io.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

java.io.IOException

blockUntilFinished

public void blockUntilFinished()

handleError

public void handleError(java.lang.Throwable ex)

shutdown

public void shutdown()

shutdownNow

public void shutdownNow()

setParser

public void setParser(ResponseParser responseParser)

setRequestWriter

public void setRequestWriter(RequestWriter requestWriter)