Package org.apache.solr.client.solrj.io

Class SolrClientCache

java.lang.Object

org.apache.solr.client.solrj.io.SolrClientCache

All Implemented Interfaces:

Closeable, AutoCloseable

public class SolrClientCache
extends Object
implements Closeable

The SolrClientCache caches SolrClients, so they can be reused by different TupleStreams.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	basicAuthCredentials

Constructor Summary

Constructors

Constructor	Description
SolrClientCache()
SolrClientCache(org.apache.solr.client.solrj.impl.HttpSolrClientBase httpSolrClient)

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.solr.client.solrj.impl.CloudSolrClient	getCloudSolrClient(String zkHost)
org.apache.solr.client.solrj.SolrClient	getHttpSolrClient(String baseUrl)	Create (and cache) a SolrClient based around the provided URL
protected org.apache.solr.client.solrj.impl.CloudSolrClient	newCloudSolrClient(String zkHost, org.apache.solr.client.solrj.impl.HttpSolrClientBase httpSolrClient, boolean canUseACLs)
protected org.apache.solr.client.solrj.impl.HttpSolrClientBuilderBase<?,?>	newHttpSolrClientBuilder(String url, org.apache.solr.client.solrj.impl.HttpSolrClientBase httpSolrClient)
void	setBasicAuthCredentials(String basicAuthCredentials)
void	setDefaultZKHost(String zkHost)

Methods inherited from class java.lang.Object

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

Field Details

basicAuthCredentials

protected String basicAuthCredentials

Constructor Details

SolrClientCache

public SolrClientCache()

SolrClientCache

public SolrClientCache(org.apache.solr.client.solrj.impl.HttpSolrClientBase httpSolrClient)

Method Details

setBasicAuthCredentials

public void setBasicAuthCredentials(String basicAuthCredentials)

setDefaultZKHost

public void setDefaultZKHost(String zkHost)

getCloudSolrClient

public org.apache.solr.client.solrj.impl.CloudSolrClient getCloudSolrClient(String zkHost)

newCloudSolrClient

protected org.apache.solr.client.solrj.impl.CloudSolrClient newCloudSolrClient(String zkHost,
 org.apache.solr.client.solrj.impl.HttpSolrClientBase httpSolrClient,
 boolean canUseACLs)

getHttpSolrClient

public org.apache.solr.client.solrj.SolrClient getHttpSolrClient(String baseUrl)

Create (and cache) a SolrClient based around the provided URL

Parameters:

baseUrl - a Solr URL. May either be a "base" URL (i.e. ending in "/solr"), or point to a particular collection or core.

Returns:

a SolrClient configured to use the provided URL. The cache retains a reference to the returned client, and will close it when callers invoke close()

newHttpSolrClientBuilder

protected org.apache.solr.client.solrj.impl.HttpSolrClientBuilderBase<?,?> newHttpSolrClientBuilder(String url,
 org.apache.solr.client.solrj.impl.HttpSolrClientBase httpSolrClient)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable