com.lucidworks.apollo.component

Class BufferingSolrServer

java.lang.Object

org.apache.solr.client.solrj.SolrClient

com.lucidworks.apollo.component.BufferingSolrServer

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable

public class BufferingSolrServer
extends SolrClient

Simple class that wraps SolrClient instance and adds a simple buffer on top of it. The life cycle of wrapped SolrClient instance should be managed elsewhere. You should properly shutdown this instance with a shutdown method.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BufferingSolrServer(SolrClient delegate, int maxBufferSize, long maxFlushIntervalMillis)
BufferingSolrServer(SolrClient delegate, int maxBufferSize, long maxFlushIntervalMillis, int concurrency, String searchClusterName, String collectionId, MetricRegistry metricRegistry, String defaultSolrCollection)

Method Summary

Modifier and Type	Method and Description
org.apache.solr.client.solrj.response.UpdateResponse	add(Collection<SolrInputDocument> docs)
org.apache.solr.client.solrj.response.UpdateResponse	add(Collection<SolrInputDocument> docs, int commitWithinMs)
org.apache.solr.client.solrj.response.UpdateResponse	add(SolrInputDocument doc, int commitWithinMs)
org.apache.solr.client.solrj.response.UpdateResponse	add(String solrCollection, Collection<SolrInputDocument> docs, int commitWithinMs)
org.apache.solr.client.solrj.response.UpdateResponse	add(String collection, SolrInputDocument doc, int commitWithinMs)
void	close()
int	flush()
NamedList<Object>	request(SolrRequest request, String collection)
void	syncFlush()

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferingSolrServer

public BufferingSolrServer(SolrClient delegate,
                           int maxBufferSize,
                           long maxFlushIntervalMillis)

BufferingSolrServer

public BufferingSolrServer(SolrClient delegate,
                           int maxBufferSize,
                           long maxFlushIntervalMillis,
                           int concurrency,
                           String searchClusterName,
                           String collectionId,
                           MetricRegistry metricRegistry,
                           String defaultSolrCollection)

Parameters:

delegate -

maxBufferSize -

maxFlushIntervalMillis -

concurrency -

searchClusterName - for diagnostic purposes only

collectionId - for diagnostic purposes only

metricRegistry -

Method Detail

syncFlush

public void syncFlush()

flush

public int flush()

close

public void close()
           throws IOException

Throws:

IOException

add

public org.apache.solr.client.solrj.response.UpdateResponse add(SolrInputDocument doc,
                                                                int commitWithinMs)
                                                         throws SolrServerException,
                                                                IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public org.apache.solr.client.solrj.response.UpdateResponse add(Collection<SolrInputDocument> docs)
                                                         throws SolrServerException,
                                                                IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public org.apache.solr.client.solrj.response.UpdateResponse add(Collection<SolrInputDocument> docs,
                                                                int commitWithinMs)
                                                         throws SolrServerException,
                                                                IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public org.apache.solr.client.solrj.response.UpdateResponse add(String solrCollection,
                                                                Collection<SolrInputDocument> docs,
                                                                int commitWithinMs)
                                                         throws SolrServerException,
                                                                IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public org.apache.solr.client.solrj.response.UpdateResponse add(String collection,
                                                                SolrInputDocument doc,
                                                                int commitWithinMs)
                                                         throws SolrServerException,
                                                                IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

request

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

Specified by:

request in class SolrClient

Throws:

SolrServerException

IOException