com.lucidworks.cloud.api.solr

Class SolrClusterComponent

java.lang.Object

com.lucidworks.cloud.api.solr.SolrClusterComponent

All Implemented Interfaces:

com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware

@Component
public class SolrClusterComponent
extends Object
implements com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware

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

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description

SolrClusterComponent(com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClient solrClusterDiscoveryClient, com.lucidworks.apollo.component.CollectionStore collectionStore, com.lucidworks.apollo.component.CollectionComponent collectionComponent, com.lucidworks.apollo.component.ConfigurationComponent configurationComponent, com.lucidworks.apollo.component.AuthContextComponent authContextComponent, com.lucidworks.apollo.component.CuratorComponent curatorComponent)

Method Summary

Modifier and Type	Method and Description
void	flushBuffers()
com.lucidworks.apollo.common.auth.AuthContext	getAuthContext(com.lucidworks.apollo.common.models.SearchCluster searchCluster)
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)
com.lucidworks.apollo.partitioning.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.
void	onCollectionAdded(String collectionId)
void	onCollectionRemoved(String collectionId)
void	onCollectionUpdated(String collectionId)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

SolrClusterComponent

@Inject
public SolrClusterComponent(com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClient solrClusterDiscoveryClient,
                                    com.lucidworks.apollo.component.CollectionStore collectionStore,
                                    com.lucidworks.apollo.component.CollectionComponent collectionComponent,
                                    com.lucidworks.apollo.component.ConfigurationComponent configurationComponent,
                                    com.lucidworks.apollo.component.AuthContextComponent authContextComponent,
                                    com.lucidworks.apollo.component.CuratorComponent curatorComponent)

Method Detail

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)

getAuthContext

public com.lucidworks.apollo.common.auth.AuthContext getAuthContext(com.lucidworks.apollo.common.models.SearchCluster searchCluster)

flushBuffers

public void flushBuffers()

shutdown

@PreDestroy
public void shutdown()

getDocumentAssignmentStrategy

public com.lucidworks.apollo.partitioning.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 com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware

onCollectionAdded

public void onCollectionAdded(String collectionId)

Specified by:

onCollectionAdded in interface com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware

onCollectionUpdated

public void onCollectionUpdated(String collectionId)

Specified by:

onCollectionUpdated in interface com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware