Package org.apache.manifoldcf.agents.output.solr

Class ModifiedCloudHttp2SolrClient

java.lang.Object

org.apache.solr.client.solrj.SolrClient

org.apache.manifoldcf.agents.output.solr.ModifiedCloudSolrClient

org.apache.manifoldcf.agents.output.solr.ModifiedCloudHttp2SolrClient

All Implemented Interfaces:

java.io.Closeable, java.io.Serializable, java.lang.AutoCloseable

public class ModifiedCloudHttp2SolrClient
extends ModifiedCloudSolrClient

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ModifiedCloudHttp2SolrClient.Builder	Constructs CloudHttp2SolrClient instances from provided configuration.

Nested classes/interfaces inherited from class org.apache.manifoldcf.agents.output.solr.ModifiedCloudSolrClient

ModifiedCloudSolrClient.RouteException, ModifiedCloudSolrClient.RouteResponse<T extends ModifiedLBSolrClient.Req>

Field Summary

Fields inherited from class org.apache.manifoldcf.agents.output.solr.ModifiedCloudSolrClient

collectionStateCache, STATE_VERSION

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ModifiedCloudHttp2SolrClient(ModifiedCloudHttp2SolrClient.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()
org.apache.solr.client.solrj.impl.ClusterStateProvider	getClusterStateProvider()
ModifiedHttp2SolrClient	getHttpClient()
ModifiedLBHttp2SolrClient	getLbClient()
protected boolean	wasCommError(java.lang.Throwable rootCause)

Methods inherited from class org.apache.manifoldcf.agents.output.solr.ModifiedCloudSolrClient

condenseResponse, condenseResponse, connect, connect, createRoutes, getClusterState, getDefaultCollection, getDocCollection, getMinAchievedReplicationFactor, getParser, getRequestWriter, getRouteException, getShardReplicationFactor, isDirectUpdatesToLeadersOnly, isParallelUpdates, isUpdatesToLeaders, objectList, request, requestWithRetryOnStaleState, sendRequest, setCollectionCacheTTl, setDefaultCollection, setParallelCacheRefreshes, setParser, setRequestWriter, setRetryExpiryTime

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ModifiedCloudHttp2SolrClient

protected ModifiedCloudHttp2SolrClient(ModifiedCloudHttp2SolrClient.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 ModifiedHttp2SolrClient.Builder with the options used to create the client.

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Overrides:

close in class ModifiedCloudSolrClient

Throws:

java.io.IOException

getLbClient

public ModifiedLBHttp2SolrClient getLbClient()

Specified by:

getLbClient in class ModifiedCloudSolrClient

getClusterStateProvider

public org.apache.solr.client.solrj.impl.ClusterStateProvider getClusterStateProvider()

Specified by:

getClusterStateProvider in class ModifiedCloudSolrClient

getHttpClient

public ModifiedHttp2SolrClient getHttpClient()

wasCommError

protected boolean wasCommError(java.lang.Throwable rootCause)

Specified by:

wasCommError in class ModifiedCloudSolrClient