Class ConcurrentUpdateHttp2SolrClient
- java.lang.Object
-
- org.apache.solr.client.solrj.SolrClient
-
- org.apache.solr.client.solrj.impl.ConcurrentUpdateHttp2SolrClient
-
- All Implemented Interfaces:
Closeable
,Serializable
,AutoCloseable
public class ConcurrentUpdateHttp2SolrClient extends SolrClient
- See Also:
- Serialized Form
- WARNING: This API is experimental and might change in incompatible ways in the next release.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ConcurrentUpdateHttp2SolrClient.Builder
ConstructsConcurrentUpdateHttp2SolrClient
instances from provided configuration.
-
Constructor Summary
Constructors Modifier Constructor Description protected
ConcurrentUpdateHttp2SolrClient(ConcurrentUpdateHttp2SolrClient.Builder builder)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
blockUntilFinished()
void
close()
void
handleError(Throwable ex)
void
onSuccess(org.eclipse.jetty.client.api.Response resp, InputStream respBody)
Intended to be used as an extension point for doing post processing after a request completes.NamedList<Object>
request(SolrRequest<?> request, String collection)
Execute a request against a Solr server for a given collectionvoid
setPollQueueTime(int pollQueueTime)
void
shutdownNow()
-
Methods inherited from class org.apache.solr.client.solrj.SolrClient
add, add, add, add, add, 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, getContext, optimize, optimize, optimize, optimize, optimize, optimize, ping, ping, query, query, query, query, queryAndStreamResponse, queryAndStreamResponse, queryAndStreamResponse, request, rollback, rollback
-
-
-
-
Constructor Detail
-
ConcurrentUpdateHttp2SolrClient
protected ConcurrentUpdateHttp2SolrClient(ConcurrentUpdateHttp2SolrClient.Builder builder)
-
-
Method Detail
-
request
public NamedList<Object> request(SolrRequest<?> request, String collection) throws SolrServerException, IOException
Description copied from class:SolrClient
Execute a request against a Solr server for a given collection- Specified by:
request
in classSolrClient
- Parameters:
request
- the request to executecollection
- the collection to execute the request against- Returns:
- a
NamedList
containing the response from the server - Throws:
SolrServerException
- if there is an error on the serverIOException
- If there is a low-level I/O error.
-
blockUntilFinished
public void blockUntilFinished() throws IOException
- Throws:
IOException
-
handleError
public void handleError(Throwable ex)
-
onSuccess
public void onSuccess(org.eclipse.jetty.client.api.Response resp, InputStream respBody)
Intended to be used as an extension point for doing post processing after a request completes.- Parameters:
respBody
- the body of the response, subclasses must not close this stream.
-
close
public void close()
-
shutdownNow
public void shutdownNow()
-
setPollQueueTime
public void setPollQueueTime(int pollQueueTime)
- Parameters:
pollQueueTime
- time for an open connection to wait for updates when the queue is empty.
-
-