Class SolrClientCloudManager
- java.lang.Object
-
- org.apache.solr.client.solrj.impl.SolrClientCloudManager
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,SolrCloudManager
,SolrCloseable
public class SolrClientCloudManager extends Object implements SolrCloudManager
Class that implementsSolrCloudManager
using a SolrClient
-
-
Field Summary
Fields Modifier and Type Field Description protected CloudLegacySolrClient
solrClient
-
Constructor Summary
Constructors Constructor Description SolrClientCloudManager(DistributedQueueFactory queueFactory, CloudLegacySolrClient solrClient)
SolrClientCloudManager(DistributedQueueFactory queueFactory, CloudLegacySolrClient solrClient, ObjectCache objectCache)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
ClusterStateProvider
getClusterStateProvider()
DistribStateManager
getDistribStateManager()
DistributedQueueFactory
getDistributedQueueFactory()
NodeStateProvider
getNodeStateProvider()
ObjectCache
getObjectCache()
TimeSource
getTimeSource()
SolrZkClient
getZkClient()
byte[]
httpRequest(String url, SolrRequest.METHOD method, Map<String,String> headers, String payload, int timeout, boolean followRedirects)
boolean
isClosed()
<T extends SolrResponse>
Trequest(SolrRequest<T> req)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.solr.client.solrj.cloud.SolrCloudManager
getClusterState
-
-
-
-
Field Detail
-
solrClient
protected final CloudLegacySolrClient solrClient
-
-
Constructor Detail
-
SolrClientCloudManager
public SolrClientCloudManager(DistributedQueueFactory queueFactory, CloudLegacySolrClient solrClient)
-
SolrClientCloudManager
public SolrClientCloudManager(DistributedQueueFactory queueFactory, CloudLegacySolrClient solrClient, ObjectCache objectCache)
-
-
Method Detail
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
-
isClosed
public boolean isClosed()
- Specified by:
isClosed
in interfaceSolrCloseable
-
getObjectCache
public ObjectCache getObjectCache()
- Specified by:
getObjectCache
in interfaceSolrCloudManager
-
getTimeSource
public TimeSource getTimeSource()
- Specified by:
getTimeSource
in interfaceSolrCloudManager
-
getClusterStateProvider
public ClusterStateProvider getClusterStateProvider()
- Specified by:
getClusterStateProvider
in interfaceSolrCloudManager
-
getNodeStateProvider
public NodeStateProvider getNodeStateProvider()
- Specified by:
getNodeStateProvider
in interfaceSolrCloudManager
-
getDistribStateManager
public DistribStateManager getDistribStateManager()
- Specified by:
getDistribStateManager
in interfaceSolrCloudManager
-
request
public <T extends SolrResponse> T request(SolrRequest<T> req) throws IOException
- Specified by:
request
in interfaceSolrCloudManager
- Throws:
IOException
-
httpRequest
public byte[] httpRequest(String url, SolrRequest.METHOD method, Map<String,String> headers, String payload, int timeout, boolean followRedirects) throws IOException
- Specified by:
httpRequest
in interfaceSolrCloudManager
- Throws:
IOException
-
getZkClient
public SolrZkClient getZkClient()
-
getDistributedQueueFactory
public DistributedQueueFactory getDistributedQueueFactory()
- Specified by:
getDistributedQueueFactory
in interfaceSolrCloudManager
-
-