com.lucidworks.apollo.component

Class BufferingSolrServer

java.lang.Object

SolrClient

com.lucidworks.apollo.component.BufferingSolrServer

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.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
UpdateResponse	add(java.util.Collection<SolrInputDocument> docs)
UpdateResponse	add(java.util.Collection<SolrInputDocument> docs, int commitWithinMs)
UpdateResponse	add(SolrInputDocument doc, int commitWithinMs)
UpdateResponse	add(java.lang.String solrCollection, java.util.Collection<SolrInputDocument> docs, int commitWithinMs)
UpdateResponse	add(java.lang.String collection, SolrInputDocument doc, int commitWithinMs)
void	close()
int	flush()
<any>	request(SolrRequest request, java.lang.String collection)
void	syncFlush()

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,
                           java.lang.String searchClusterName,
                           java.lang.String collectionId,
                           MetricRegistry metricRegistry,
                           java.lang.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 java.io.IOException

Throws:

java.io.IOException

add

public UpdateResponse add(SolrInputDocument doc,
                          int commitWithinMs)
                   throws SolrServerException,
                          java.io.IOException

Throws:

SolrServerException

java.io.IOException

add

public UpdateResponse add(java.util.Collection<SolrInputDocument> docs)
                   throws SolrServerException,
                          java.io.IOException

Throws:

SolrServerException

java.io.IOException

add

public UpdateResponse add(java.util.Collection<SolrInputDocument> docs,
                          int commitWithinMs)
                   throws SolrServerException,
                          java.io.IOException

Throws:

SolrServerException

java.io.IOException

add

public UpdateResponse add(java.lang.String solrCollection,
                          java.util.Collection<SolrInputDocument> docs,
                          int commitWithinMs)
                   throws SolrServerException,
                          java.io.IOException

Throws:

SolrServerException

java.io.IOException

add

public UpdateResponse add(java.lang.String collection,
                          SolrInputDocument doc,
                          int commitWithinMs)
                   throws SolrServerException,
                          java.io.IOException

Throws:

SolrServerException

java.io.IOException

request

public <any> request(SolrRequest request,
                     java.lang.String collection)
              throws SolrServerException,
                     java.io.IOException

Throws:

SolrServerException

java.io.IOException