Package com.lucidworks.cloud.api.solr

Class PipelineCloudSolrClient

java.lang.Object
org.apache.solr.client.solrj.SolrClient
org.apache.solr.client.solrj.impl.CloudSolrClient
com.lucidworks.cloud.api.solr.PipelineCloudSolrClient
All Implemented Interfaces:
Closeable, Serializable, AutoCloseable
public class PipelineCloudSolrClient extends org.apache.solr.client.solrj.impl.CloudSolrClient
Create a new client object that connects to Zookeeper and is always aware of the SolrCloud state. Updates will be sent to shard leaders by default.
See Also:

  • Nested Class Summary

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

    org.apache.solr.client.solrj.impl.CloudSolrClient.Builder, org.apache.solr.client.solrj.impl.CloudSolrClient.RouteException, org.apache.solr.client.solrj.impl.CloudSolrClient.RouteResponse<T extends org.apache.solr.client.solrj.impl.LBSolrClient.Req>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected static final org.slf4j.Logger
    log
     

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

    collectionStateCache, STATE_VERSION

  • Constructor Summary

    Constructors
    Constructor
    Description
    PipelineCloudSolrClient(com.lucidworks.apollo.common.models.SearchCluster searchCluster)
     
    PipelineCloudSolrClient(org.apache.solr.client.solrj.impl.ZkClientClusterStateProvider zkClientClusterStateProvider)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.solr.client.solrj.impl.ClusterStateProvider
    getClusterStateProvider()
     
    protected org.apache.solr.client.solrj.impl.LBSolrClient
    getLbClient()
     
    protected boolean
    wasCommError(Throwable t)
     

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

    close, 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

  • Field Details

    • log

      protected static final org.slf4j.Logger log

  • Constructor Details

    • PipelineCloudSolrClient

      public PipelineCloudSolrClient(org.apache.solr.client.solrj.impl.ZkClientClusterStateProvider zkClientClusterStateProvider)

    • PipelineCloudSolrClient

      public PipelineCloudSolrClient(com.lucidworks.apollo.common.models.SearchCluster searchCluster)

  • Method Details

    • getLbClient

      protected org.apache.solr.client.solrj.impl.LBSolrClient getLbClient()
      Specified by:
      getLbClient in class org.apache.solr.client.solrj.impl.CloudSolrClient

    • getClusterStateProvider

      public org.apache.solr.client.solrj.impl.ClusterStateProvider getClusterStateProvider()
      Specified by:
      getClusterStateProvider in class org.apache.solr.client.solrj.impl.CloudSolrClient

    • wasCommError

      protected boolean wasCommError(Throwable t)
      Specified by:
      wasCommError in class org.apache.solr.client.solrj.impl.CloudSolrClient