Package com.lucidworks.apollo.partitioning

Class DefaultDocumentAssignmentStrategy

java.lang.Object

com.lucidworks.apollo.partitioning.DefaultDocumentAssignmentStrategy

All Implemented Interfaces:

DocumentAssignmentStrategy, Serializable

public class DefaultDocumentAssignmentStrategy
extends Object
implements DocumentAssignmentStrategy

Default assignment strategy just selects the configured Solr collection to send documents to, i.e. no collection-level partitioning.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DefaultDocumentAssignmentStrategy(String solrCollectionName)

Method Summary

Modifier and Type	Method	Description
void	deleteAllPartitions()	Delete all partitions created by this strategy.
void	deletePartition(String partitionId)	Deletes a partition managed by this strategy.
void	doScheduledMaintenanceOnPartitions()	Called in the background at a regular interval to allow the strategy to perform maintenance on the partitions.
String	getOrCreatePartitionForDoc(com.lucidworks.apollo.common.pipeline.PipelineDocument doc)	Returns the name of a Solr collection where a document should be assigned to based on this strategy.
List<String>	getPartitions(boolean activeOnly)	Returns a list of Solr collection names where documents have been assigned by this strategy.
List<String>	getPartitionsForQuery(javax.ws.rs.core.MultivaluedMap<String,String> queryParams)	Returns a list of Solr collection names that need to be queried to satisfy the query criteria.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultDocumentAssignmentStrategy

public DefaultDocumentAssignmentStrategy(String solrCollectionName)

Method Details

getPartitions

public List<String> getPartitions(boolean activeOnly)
                           throws Exception

Description copied from interface: DocumentAssignmentStrategy

Returns a list of Solr collection names where documents have been assigned by this strategy.

Specified by:

getPartitions in interface DocumentAssignmentStrategy

Throws:

Exception

getPartitionsForQuery

public List<String> getPartitionsForQuery(javax.ws.rs.core.MultivaluedMap<String,String> queryParams)
                                   throws Exception

Description copied from interface: DocumentAssignmentStrategy

Returns a list of Solr collection names that need to be queried to satisfy the query criteria.

Specified by:

getPartitionsForQuery in interface DocumentAssignmentStrategy

Throws:

Exception

getOrCreatePartitionForDoc

public String getOrCreatePartitionForDoc(com.lucidworks.apollo.common.pipeline.PipelineDocument doc)
                                  throws Exception

Description copied from interface: DocumentAssignmentStrategy

Returns the name of a Solr collection where a document should be assigned to based on this strategy.

Specified by:

getOrCreatePartitionForDoc in interface DocumentAssignmentStrategy

Throws:

Exception

deletePartition

public void deletePartition(String partitionId)
                     throws Exception

Description copied from interface: DocumentAssignmentStrategy

Deletes a partition managed by this strategy.

Specified by:

deletePartition in interface DocumentAssignmentStrategy

Throws:

Exception

deleteAllPartitions

public void deleteAllPartitions()
                         throws Exception

Description copied from interface: DocumentAssignmentStrategy

Delete all partitions created by this strategy.

Specified by:

deleteAllPartitions in interface DocumentAssignmentStrategy

Throws:

Exception

doScheduledMaintenanceOnPartitions

public void doScheduledMaintenanceOnPartitions()
                                        throws Exception

Description copied from interface: DocumentAssignmentStrategy

Called in the background at a regular interval to allow the strategy to perform maintenance on the partitions.

Specified by:

doScheduledMaintenanceOnPartitions in interface DocumentAssignmentStrategy

Throws:

Exception