Package org.apache.solr.client.solrj.impl

Class CloudHttp2SolrClient

java.lang.Object

org.apache.solr.client.solrj.SolrClient

org.apache.solr.client.solrj.impl.BaseCloudSolrClient

org.apache.solr.client.solrj.impl.CloudHttp2SolrClient

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable

public class CloudHttp2SolrClient
extends BaseCloudSolrClient

SolrJ client class to communicate with SolrCloud using Http2SolrClient. Instances of this class communicate with Zookeeper to discover Solr endpoints for SolrCloud collections, and then use the LBHttp2SolrClient to issue requests. This class assumes the id field for your documents is called 'id' - if this is not the case, you must set the right name with BaseCloudSolrClient.setIdField(String).

Since:

solr 8.0

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	CloudHttp2SolrClient.Builder	Constructs CloudHttp2SolrClient instances from provided configuration.

Nested classes/interfaces inherited from class org.apache.solr.client.solrj.impl.BaseCloudSolrClient

BaseCloudSolrClient.RouteException, BaseCloudSolrClient.RouteResponse<T extends LBSolrClient.Req>

Field Summary

Fields inherited from class org.apache.solr.client.solrj.impl.BaseCloudSolrClient

collectionStateCache, STATE_VERSION

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CloudHttp2SolrClient(CloudHttp2SolrClient.Builder builder)	Create a new client object that connects to Zookeeper and is always aware of the SolrCloud state.

Method Summary

Modifier and Type	Method	Description
void	close()
ClusterStateProvider	getClusterStateProvider()
Http2SolrClient	getHttpClient()
LBHttp2SolrClient	getLbClient()
protected boolean	wasCommError(Throwable rootCause)

Methods inherited from class org.apache.solr.client.solrj.impl.BaseCloudSolrClient

condenseResponse, condenseResponse, connect, connect, createRoutes, getDefaultCollection, getDocCollection, getIdField, getMinAchievedReplicationFactor, getParser, getRequestWriter, getRouteException, getShardReplicationFactor, getZkHost, getZkStateReader, isDirectUpdatesToLeadersOnly, isParallelUpdates, isUpdatesToLeaders, objectList, registerCollectionStateWatcher, request, requestWithRetryOnStaleState, sendRequest, setCollectionCacheTTl, setDefaultCollection, setIdField, setParallelCacheRefreshes, setParser, setRequestWriter, setRetryExpiryTime, setZkClientTimeout, setZkConnectTimeout, waitForState

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, optimize, optimize, optimize, optimize, optimize, optimize, ping, query, query, query, query, queryAndStreamResponse, queryAndStreamResponse, queryAndStreamResponse, request, rollback, rollback

Methods inherited from class java.lang.Object

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

Constructor Detail

CloudHttp2SolrClient

protected CloudHttp2SolrClient(CloudHttp2SolrClient.Builder builder)

Create a new client object that connects to Zookeeper and is always aware of the SolrCloud state. If there is a fully redundant Zookeeper quorum and SolrCloud has enough replicas for every shard in a collection, there is no single point of failure. Updates will be sent to shard leaders by default.

Parameters:

builder - a Http2SolrClient.Builder with the options used to create the client.

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class BaseCloudSolrClient

Throws:

IOException

getLbClient

public LBHttp2SolrClient getLbClient()

Specified by:

getLbClient in class BaseCloudSolrClient

getClusterStateProvider

public ClusterStateProvider getClusterStateProvider()

Specified by:

getClusterStateProvider in class BaseCloudSolrClient

getHttpClient

public Http2SolrClient getHttpClient()

wasCommError

protected boolean wasCommError(Throwable rootCause)

Specified by:

wasCommError in class BaseCloudSolrClient