Package | Description |
---|---|
org.apache.solr |
Commonly reused classes and interfaces (deprecated package, do not add new classes)
|
org.apache.solr.client.solrj |
Primary APIs for communicating with a Solr Server from a Java client.
|
org.apache.solr.client.solrj.embedded |
SolrJ client implementations for embedded solr access.
|
org.apache.solr.client.solrj.impl |
Concrete implementations of client API classes.
|
org.apache.solr.client.solrj.io.stream |
Stream implementations for the Streaming Aggregation API
|
org.apache.solr.client.solrj.request |
Convenience classes for dealing with various types of Solr requests.
|
org.apache.solr.cloud |
Classes for dealing with ZooKeeper when operating in SolrCloud mode.
|
org.apache.solr.cloud.rule |
Classes for managing Replica placement strategy when operating in SolrCloud mode.
|
org.apache.solr.handler.component |
SearchComponent implementations for
use in SearchHandler |
Modifier and Type | Method and Description |
---|---|
protected UpdateResponse |
BaseDistributedSearchTestCase.add(SolrClient client,
SolrParams params,
SolrInputDocument... sdocs) |
void |
SolrTestCaseHS.Client.commit() |
protected UpdateResponse |
BaseDistributedSearchTestCase.del(SolrClient client,
SolrParams params,
Object... ids) |
void |
SolrTestCaseHS.Client.deleteByQuery(String query,
ModifiableSolrParams params) |
protected UpdateResponse |
BaseDistributedSearchTestCase.delQ(SolrClient client,
SolrParams params,
String... queries) |
protected UpdateResponse |
BaseDistributedSearchTestCase.indexDoc(SolrClient client,
SolrParams params,
SolrInputDocument... sdocs)
Indexes the document in both the control client and the specified client asserting
that the respones are equivilent
|
protected void |
BaseDistributedSearchTestCase.indexDoc(SolrInputDocument doc)
Indexes the document in both the control client, and a randomly selected client
|
QueryResponse |
BaseDistributedSearchTestCase.queryAndCompare(SolrParams params,
Iterable<SolrClient> clients) |
QueryResponse |
BaseDistributedSearchTestCase.queryAndCompare(SolrParams params,
SolrClient... clients) |
protected QueryResponse |
BaseDistributedSearchTestCase.queryServer(ModifiableSolrParams params) |
Modifier and Type | Method and Description |
---|---|
UpdateResponse |
SolrClient.add(Collection<SolrInputDocument> docs)
Adds a collection of documents
|
UpdateResponse |
SolrClient.add(Collection<SolrInputDocument> docs,
int commitWithinMs)
Adds a collection of documents, specifying max time before they become committed
|
UpdateResponse |
SolrClient.add(Iterator<SolrInputDocument> docIterator)
Adds the documents supplied by the given iterator.
|
UpdateResponse |
SolrClient.add(SolrInputDocument doc)
Adds a single document
|
UpdateResponse |
SolrClient.add(SolrInputDocument doc,
int commitWithinMs)
Adds a single document specifying max time before it becomes committed
|
UpdateResponse |
SolrClient.add(String collection,
Collection<SolrInputDocument> docs)
Adds a collection of documents
|
UpdateResponse |
SolrClient.add(String collection,
Collection<SolrInputDocument> docs,
int commitWithinMs)
Adds a collection of documents, specifying max time before they become committed
|
UpdateResponse |
SolrClient.add(String collection,
Iterator<SolrInputDocument> docIterator)
Adds the documents supplied by the given iterator.
|
UpdateResponse |
SolrClient.add(String collection,
SolrInputDocument doc)
Adds a single document
|
UpdateResponse |
SolrClient.add(String collection,
SolrInputDocument doc,
int commitWithinMs)
Adds a single document specifying max time before it becomes committed
|
UpdateResponse |
SolrClient.addBean(Object obj)
Adds a single bean
The bean is converted to a
SolrInputDocument by the client's
DocumentObjectBinder |
UpdateResponse |
SolrClient.addBean(Object obj,
int commitWithinMs)
Adds a single bean specifying max time before it becomes committed
The bean is converted to a
SolrInputDocument by the client's
DocumentObjectBinder |
UpdateResponse |
SolrClient.addBean(String collection,
Object obj)
Adds a single bean
The bean is converted to a
SolrInputDocument by the client's
DocumentObjectBinder |
UpdateResponse |
SolrClient.addBean(String collection,
Object obj,
int commitWithinMs)
Adds a single bean specifying max time before it becomes committed
The bean is converted to a
SolrInputDocument by the client's
DocumentObjectBinder |
UpdateResponse |
SolrClient.addBeans(Collection<?> beans)
Adds a collection of beans
The beans are converted to
SolrInputDocument s by the client's
DocumentObjectBinder |
UpdateResponse |
SolrClient.addBeans(Collection<?> beans,
int commitWithinMs)
Adds a collection of beans specifying max time before they become committed
The beans are converted to
SolrInputDocument s by the client's
DocumentObjectBinder |
UpdateResponse |
SolrClient.addBeans(Iterator<?> beanIterator)
Adds the beans supplied by the given iterator.
|
UpdateResponse |
SolrClient.addBeans(String collection,
Collection<?> beans)
Adds a collection of beans
The beans are converted to
SolrInputDocument s by the client's
DocumentObjectBinder |
UpdateResponse |
SolrClient.addBeans(String collection,
Collection<?> beans,
int commitWithinMs)
Adds a collection of beans specifying max time before they become committed
The beans are converted to
SolrInputDocument s by the client's
DocumentObjectBinder |
UpdateResponse |
SolrClient.addBeans(String collection,
Iterator<?> beanIterator)
Adds the beans supplied by the given iterator.
|
UpdateResponse |
SolrClient.commit()
Performs an explicit commit, causing pending documents to be committed for indexing
waitFlush=true and waitSearcher=true to be inline with the defaults for plain HTTP access
|
UpdateResponse |
SolrClient.commit(boolean waitFlush,
boolean waitSearcher)
Performs an explicit commit, causing pending documents to be committed for indexing
|
UpdateResponse |
SolrClient.commit(boolean waitFlush,
boolean waitSearcher,
boolean softCommit)
Performs an explicit commit, causing pending documents to be committed for indexing
|
UpdateResponse |
SolrClient.commit(String collection)
Performs an explicit commit, causing pending documents to be committed for indexing
waitFlush=true and waitSearcher=true to be inline with the defaults for plain HTTP access
|
UpdateResponse |
SolrClient.commit(String collection,
boolean waitFlush,
boolean waitSearcher)
Performs an explicit commit, causing pending documents to be committed for indexing
|
UpdateResponse |
SolrClient.commit(String collection,
boolean waitFlush,
boolean waitSearcher,
boolean softCommit)
Performs an explicit commit, causing pending documents to be committed for indexing
|
UpdateResponse |
SolrClient.deleteById(List<String> ids)
Deletes a list of documents by unique ID
|
UpdateResponse |
SolrClient.deleteById(List<String> ids,
int commitWithinMs)
Deletes a list of documents by unique ID, specifying max time before commit
|
UpdateResponse |
SolrClient.deleteById(String id)
Deletes a single document by unique ID
|
UpdateResponse |
SolrClient.deleteById(String id,
int commitWithinMs)
Deletes a single document by unique ID, specifying max time before commit
|
UpdateResponse |
SolrClient.deleteById(String collection,
List<String> ids)
Deletes a list of documents by unique ID
|
UpdateResponse |
SolrClient.deleteById(String collection,
List<String> ids,
int commitWithinMs)
Deletes a list of documents by unique ID, specifying max time before commit
|
UpdateResponse |
SolrClient.deleteById(String collection,
String id)
Deletes a single document by unique ID
|
UpdateResponse |
SolrClient.deleteById(String collection,
String id,
int commitWithinMs)
Deletes a single document by unique ID, specifying max time before commit
|
UpdateResponse |
SolrClient.deleteByQuery(String query)
Deletes documents from the index based on a query
|
UpdateResponse |
SolrClient.deleteByQuery(String query,
int commitWithinMs)
Deletes documents from the index based on a query, specifying max time before commit
|
UpdateResponse |
SolrClient.deleteByQuery(String collection,
String query)
Deletes documents from the index based on a query
|
UpdateResponse |
SolrClient.deleteByQuery(String collection,
String query,
int commitWithinMs)
Deletes documents from the index based on a query, specifying max time before commit
|
SolrDocumentList |
SolrClient.getById(Collection<String> ids)
Retrieves the SolrDocuments associated with the given identifiers.
|
SolrDocumentList |
SolrClient.getById(Collection<String> ids,
SolrParams params)
Retrieves the SolrDocuments associated with the given identifiers and uses
the SolrParams to execute the request.
|
SolrDocument |
SolrClient.getById(String id)
Retrieves the SolrDocument associated with the given identifier.
|
SolrDocumentList |
SolrClient.getById(String collection,
Collection<String> ids)
Retrieves the SolrDocuments associated with the given identifiers.
|
SolrDocumentList |
SolrClient.getById(String collection,
Collection<String> ids,
SolrParams params)
Retrieves the SolrDocuments associated with the given identifiers and uses
the SolrParams to execute the request.
|
SolrDocument |
SolrClient.getById(String id,
SolrParams params)
Retrieves the SolrDocument associated with the given identifier and uses
the SolrParams to execute the request.
|
SolrDocument |
SolrClient.getById(String collection,
String id)
Retrieves the SolrDocument associated with the given identifier.
|
SolrDocument |
SolrClient.getById(String collection,
String id,
SolrParams params)
Retrieves the SolrDocument associated with the given identifier and uses
the SolrParams to execute the request.
|
UpdateResponse |
SolrClient.optimize()
Performs an explicit optimize, causing a merge of all segments to one.
|
UpdateResponse |
SolrClient.optimize(boolean waitFlush,
boolean waitSearcher)
Performs an explicit optimize, causing a merge of all segments to one.
|
UpdateResponse |
SolrClient.optimize(boolean waitFlush,
boolean waitSearcher,
int maxSegments)
Performs an explicit optimize, causing a merge of all segments to one.
|
UpdateResponse |
SolrClient.optimize(String collection)
Performs an explicit optimize, causing a merge of all segments to one.
|
UpdateResponse |
SolrClient.optimize(String collection,
boolean waitFlush,
boolean waitSearcher)
Performs an explicit optimize, causing a merge of all segments to one.
|
UpdateResponse |
SolrClient.optimize(String collection,
boolean waitFlush,
boolean waitSearcher,
int maxSegments)
Performs an explicit optimize, causing a merge of all segments to one.
|
SolrPingResponse |
SolrClient.ping()
Issues a ping request to check if the server is alive
|
T |
SolrRequest.process(SolrClient client)
Send this request to a
SolrClient and return the response |
T |
SolrRequest.process(SolrClient client,
String collection)
Send this request to a
SolrClient and return the response |
QueryResponse |
SolrClient.query(SolrParams params)
Performs a query to the Solr server
|
QueryResponse |
SolrClient.query(SolrParams params,
SolrRequest.METHOD method)
Performs a query to the Solr server
|
QueryResponse |
SolrClient.query(String collection,
SolrParams params)
Performs a query to the Solr server
|
QueryResponse |
SolrClient.query(String collection,
SolrParams params,
SolrRequest.METHOD method)
Performs a query to the Solr server
|
QueryResponse |
SolrClient.queryAndStreamResponse(SolrParams params,
StreamingResponseCallback callback)
Query solr, and stream the results.
|
QueryResponse |
SolrClient.queryAndStreamResponse(String collection,
SolrParams params,
StreamingResponseCallback callback)
Query solr, and stream the results.
|
NamedList<Object> |
SolrClient.request(SolrRequest request)
Execute a request against a Solr server
|
abstract NamedList<Object> |
SolrClient.request(SolrRequest request,
String collection)
Execute a request against a Solr server for a given collection
|
UpdateResponse |
SolrClient.rollback()
Performs a rollback of all non-committed documents pending.
|
UpdateResponse |
SolrClient.rollback(String collection)
Performs a rollback of all non-committed documents pending.
|
Modifier and Type | Method and Description |
---|---|
NamedList<Object> |
EmbeddedSolrServer.request(SolrRequest request,
String coreName) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.http.client.methods.HttpRequestBase |
HttpSolrClient.createMethod(SolrRequest request,
String collection) |
protected Exception |
LBHttpSolrClient.doRequest(HttpSolrClient client,
LBHttpSolrClient.Req req,
LBHttpSolrClient.Rsp rsp,
boolean isUpdate,
boolean isZombie,
String zombieKey) |
protected NamedList<Object> |
HttpSolrClient.executeMethod(org.apache.http.client.methods.HttpRequestBase method,
ResponseParser processor) |
HttpSolrClient.HttpUriRequestResponse |
HttpSolrClient.httpUriRequest(SolrRequest request) |
HttpSolrClient.HttpUriRequestResponse |
HttpSolrClient.httpUriRequest(SolrRequest request,
ResponseParser processor) |
LBHttpSolrClient.Rsp |
LBHttpSolrClient.request(LBHttpSolrClient.Req req)
Tries to query a live server from the list provided in Req.
|
NamedList<Object> |
HttpSolrClient.request(SolrRequest request,
ResponseParser processor) |
NamedList<Object> |
HttpSolrClient.request(SolrRequest request,
ResponseParser processor,
String collection) |
NamedList<Object> |
ConcurrentUpdateSolrClient.request(SolrRequest request,
String collection) |
NamedList<Object> |
HttpSolrClient.request(SolrRequest request,
String collection)
Process the request.
|
NamedList<Object> |
LBHttpSolrClient.request(SolrRequest request,
String collection)
Tries to query a live server.
|
NamedList<Object> |
CloudSolrClient.request(SolrRequest request,
String collection) |
protected NamedList<Object> |
CloudSolrClient.requestWithRetryOnStaleState(SolrRequest request,
int retryCount,
String collection)
As this class doesn't watch external collections on the client side,
there's a chance that the request will fail due to cached stale state,
which means the state must be refreshed from ZK and retried.
|
protected NamedList<Object> |
CloudSolrClient.sendRequest(SolrRequest request,
String collection) |
Modifier and Type | Method and Description |
---|---|
static JSONTupleStream |
JSONTupleStream.create(SolrClient server,
SolrParams requestParams) |
Modifier and Type | Method and Description |
---|---|
static CoreAdminResponse |
CoreAdminRequest.createCore(String name,
String instanceDir,
SolrClient client) |
static CoreAdminResponse |
CoreAdminRequest.createCore(String name,
String instanceDir,
SolrClient client,
String configFile,
String schemaFile) |
static CoreAdminResponse |
CoreAdminRequest.createCore(String name,
String instanceDir,
SolrClient client,
String configFile,
String schemaFile,
String dataDir,
String tlogDir) |
static CoreAdminResponse |
CoreAdminRequest.getStatus(String name,
SolrClient client) |
static CoreAdminResponse |
CoreAdminRequest.mergeIndexes(String name,
String[] indexDirs,
String[] srcCores,
SolrClient client) |
static CoreAdminResponse |
CoreAdminRequest.reloadCore(String name,
SolrClient client) |
static CoreAdminResponse |
CoreAdminRequest.renameCore(String coreName,
String newName,
SolrClient client) |
static CoreAdminResponse |
CoreAdminRequest.unloadCore(String name,
boolean deleteIndex,
boolean deleteInstanceDir,
SolrClient client) |
static CoreAdminResponse |
CoreAdminRequest.unloadCore(String name,
boolean deleteIndex,
SolrClient client) |
static CoreAdminResponse |
CoreAdminRequest.unloadCore(String name,
SolrClient client) |
Modifier and Type | Method and Description |
---|---|
static boolean |
CloudInspectUtil.compareResults(SolrClient controlClient,
SolrClient cloudClient)
Compares the results of the control and cloud clients.
|
static boolean |
CloudInspectUtil.compareResults(SolrClient controlClient,
SolrClient cloudClient,
Set<String> addFails,
Set<String> deleteFails)
Compares the results of the control and cloud clients.
|
protected CollectionAdminResponse |
AbstractFullDistribZkTestBase.createCollection(Map<String,List<Integer>> collectionInfos,
String collectionName,
int numShards,
int replicationFactor,
int maxShardsPerNode,
SolrClient client,
String createNodeSetStr) |
protected CollectionAdminResponse |
AbstractFullDistribZkTestBase.createCollection(Map<String,List<Integer>> collectionInfos,
String collectionName,
int numShards,
int replicationFactor,
int maxShardsPerNode,
SolrClient client,
String createNodeSetStr,
String configName) |
protected CollectionAdminResponse |
AbstractFullDistribZkTestBase.createCollection(Map<String,List<Integer>> collectionInfos,
String collectionName,
Map<String,Object> collectionProps,
SolrClient client) |
protected CollectionAdminResponse |
AbstractFullDistribZkTestBase.createCollection(Map<String,List<Integer>> collectionInfos,
String collectionName,
Map<String,Object> collectionProps,
SolrClient client,
String confSetName) |
protected CollectionAdminResponse |
AbstractFullDistribZkTestBase.createCollection(String collectionName,
int numShards,
int replicationFactor,
int maxShardsPerNode) |
NamedList<Object> |
MiniSolrCloudCluster.createCollection(String name,
int numShards,
int replicationFactor,
String configName,
Map<String,String> collectionProperties) |
NamedList<Object> |
MiniSolrCloudCluster.createCollection(String name,
int numShards,
int replicationFactor,
String configName,
String createNodeSet,
String asyncId,
Map<String,String> collectionProperties) |
NamedList<Object> |
MiniSolrCloudCluster.deleteCollection(String name) |
protected void |
AbstractFullDistribZkTestBase.indexDoc(SolrInputDocument doc) |
protected void |
StoppableIndexingThread.indexDocs(List<SolrInputDocument> docs) |
protected QueryResponse |
AbstractFullDistribZkTestBase.queryServer(ModifiableSolrParams params) |
Modifier and Type | Method and Description |
---|---|
SimpleSolrResponse |
SnitchContext.invoke(UpdateShardHandler shardHandler,
String url,
String path,
SolrParams params) |
Modifier and Type | Method and Description |
---|---|
LBHttpSolrClient.Rsp |
HttpShardHandlerFactory.makeLoadBalancedRequest(QueryRequest req,
List<String> urls)
Makes a request to one or more of the given urls, using the configured load balancer.
|
Copyright © 2000–2015 The Apache Software Foundation. All rights reserved.