public class DefaultUpdateClient extends AbstractAmetysConcurrentUpdateClient
SolrClient
which uses the Solr default Update Request Processor chainModifier and Type | Class and Description |
---|---|
(package private) static class |
DefaultUpdateClient.CommitNotAllowedException |
ConcurrentUpdateSolrClient.Builder
Constructor and Description |
---|
DefaultUpdateClient(String solrServerUrl,
String collectionName,
int queueSize,
int threadCount,
Logger logger)
Constructor
|
Modifier and Type | Method and Description |
---|---|
UpdateResponse |
commit() |
UpdateResponse |
commit(boolean waitFlush,
boolean waitSearcher) |
UpdateResponse |
commit(boolean waitFlush,
boolean waitSearcher,
boolean softCommit) |
UpdateResponse |
commit(String collection) |
UpdateResponse |
commit(String collection,
boolean waitFlush,
boolean waitSearcher) |
UpdateResponse |
commit(String collection,
boolean waitFlush,
boolean waitSearcher,
boolean softCommit) |
add, add, add, add, add, add, add, add, add, add, addBean, addBean, addBean, addBean, addBeans, addBeans, addBeans, addBeans, addBeans, addBeans, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteByQuery, deleteByQuery, deleteByQuery, deleteByQuery, handleError, onSuccess, optimize, optimize, optimize, optimize, optimize, optimize, rollback, rollback
blockUntilFinished, close, getQueryParams, request, setConnectionTimeout, setParser, setPollQueueTime, setQueryParams, setRequestWriter, setSoTimeout, shutdownNow
public DefaultUpdateClient(String solrServerUrl, String collectionName, int queueSize, int threadCount, Logger logger)
solrServerUrl
- The Solr server URLcollectionName
- The name of the collection, on which operations will be allowed. Operations on other collections will be forbidden.queueSize
- The buffer size before the documents are sent to the serverthreadCount
- The number of background threads used to empty the queuelogger
- internal loggerpublic UpdateResponse commit() throws SolrServerException, IOException
commit
in class AbstractAmetysConcurrentUpdateClient
SolrServerException
IOException
public UpdateResponse commit(boolean waitFlush, boolean waitSearcher) throws SolrServerException, IOException
commit
in class AbstractAmetysConcurrentUpdateClient
SolrServerException
IOException
public UpdateResponse commit(boolean waitFlush, boolean waitSearcher, boolean softCommit) throws SolrServerException, IOException
commit
in class AbstractAmetysConcurrentUpdateClient
SolrServerException
IOException
public UpdateResponse commit(String collection) throws SolrServerException, IOException
commit
in class AbstractAmetysConcurrentUpdateClient
SolrServerException
IOException
public UpdateResponse commit(String collection, boolean waitFlush, boolean waitSearcher) throws SolrServerException, IOException
commit
in class AbstractAmetysConcurrentUpdateClient
SolrServerException
IOException
public UpdateResponse commit(String collection, boolean waitFlush, boolean waitSearcher, boolean softCommit) throws SolrServerException, IOException
commit
in class AbstractAmetysConcurrentUpdateClient
SolrServerException
IOException