Package com.lucidworks.cloud.api.solr

Class SolrClusterComponent

java.lang.Object

com.lucidworks.cloud.api.solr.SolrClusterComponent

All Implemented Interfaces:

CollectionComponent.CollectionChangeAware

@EnableConfigurationProperties(ConfigurationComponent.class)
public class SolrClusterComponent
extends Object
implements CollectionComponent.CollectionChangeAware

Provides access to the Solr servers associated with a given collectionId.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SolrClusterComponent.OverrideCollectionSolrClient	Class to remember the requested collection.

Constructor Summary

Constructors

Constructor	Description
SolrClusterComponent(SolrClusterDiscoveryClient solrClusterDiscoveryClient, CollectionStore collectionStore, CollectionComponent collectionComponent, ConfigurationComponent configurationComponent, org.apache.curator.framework.CuratorFramework curatorComponent)

Method Summary

Modifier and Type	Method	Description
protected org.apache.solr.client.solrj.impl.CloudSolrClient	createSolrClientForCluster(com.lucidworks.apollo.common.models.SearchCluster searchCluster)
void	flushBuffers()
BufferingSolrServer	getBufferingSolrServer(String collectionId)
BufferingSolrServer	getBufferingSolrServer(String collectionId, Integer bufferSize, Long flushInterval)
org.apache.solr.client.solrj.impl.CloudSolrClient	getCloudSolrClient(String cluster)
com.lucidworks.apollo.common.models.Collection	getCollection(String collectionId)
int	getCommitWithin(String collectionId)
org.apache.curator.framework.CuratorFramework	getCurator(com.lucidworks.apollo.common.models.SearchCluster searchCluster)
DocumentAssignmentStrategy	getDocumentAssignmentStrategy(String collectionId)
com.lucidworks.apollo.common.models.SearchCluster	getSearchCluster(String collectionId)
org.apache.solr.client.solrj.SolrClient	getSolrClient(String collectionId)
org.apache.solr.client.solrj.SolrClient	getSolrServer(String collectionId)	Deprecated.
protected void	invalidateCachedDocumentAssignmentStrategy(String collectionId)
void	onCollectionAdded(String collectionId)
void	onCollectionRemoved(String collectionId)
void	onCollectionUpdated(String collectionId)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Details

SolrClusterComponent

@Inject
public SolrClusterComponent(SolrClusterDiscoveryClient solrClusterDiscoveryClient,
 CollectionStore collectionStore,
 CollectionComponent collectionComponent,
 ConfigurationComponent configurationComponent,
 org.apache.curator.framework.CuratorFramework curatorComponent)

Method Details

createSolrClientForCluster

protected org.apache.solr.client.solrj.impl.CloudSolrClient createSolrClientForCluster(com.lucidworks.apollo.common.models.SearchCluster searchCluster)

getSolrClient

public org.apache.solr.client.solrj.SolrClient getSolrClient(String collectionId)

getSolrServer

@Deprecated
public org.apache.solr.client.solrj.SolrClient getSolrServer(String collectionId)

Deprecated.

Exists only for javascript back-compat reasons, see APOLLO-29567

getCloudSolrClient

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

getBufferingSolrServer

public BufferingSolrServer getBufferingSolrServer(String collectionId)

getBufferingSolrServer

public BufferingSolrServer getBufferingSolrServer(String collectionId,
 Integer bufferSize,
 Long flushInterval)

getCollection

public com.lucidworks.apollo.common.models.Collection getCollection(String collectionId)

getCommitWithin

public int getCommitWithin(String collectionId)

getSearchCluster

public com.lucidworks.apollo.common.models.SearchCluster getSearchCluster(String collectionId)

flushBuffers

public void flushBuffers()

shutdown

@PreDestroy
public void shutdown()

getDocumentAssignmentStrategy

public DocumentAssignmentStrategy getDocumentAssignmentStrategy(String collectionId)

getCurator

public org.apache.curator.framework.CuratorFramework getCurator(com.lucidworks.apollo.common.models.SearchCluster searchCluster)

onCollectionRemoved

public void onCollectionRemoved(String collectionId)

Specified by:

onCollectionRemoved in interface CollectionComponent.CollectionChangeAware

onCollectionAdded

public void onCollectionAdded(String collectionId)

Specified by:

onCollectionAdded in interface CollectionComponent.CollectionChangeAware

onCollectionUpdated

public void onCollectionUpdated(String collectionId)

Specified by:

onCollectionUpdated in interface CollectionComponent.CollectionChangeAware

invalidateCachedDocumentAssignmentStrategy

protected void invalidateCachedDocumentAssignmentStrategy(String collectionId)