org.broadleafcommerce.core.search.service.solr.index

Interface SolrIndexService

All Known Implementing Classes:

SolrIndexServiceImpl

public interface SolrIndexService

Service exposing several methods for creating a Solr index based on catalog product data.

Author:

Andre Azzolini (apazzolini), Jeff Fischer, Phillip Verheyden (phillipuniverse)

See Also:

SolrIndexCachedOperation

Method Summary

Modifier and Type	Method and Description
void	addDocuments(Collection<org.apache.solr.common.SolrInputDocument> documents)
void	attachIndexableDocumentFields(org.apache.solr.common.SolrInputDocument document, Indexable indexable, List<IndexField> fields, List<Locale> locales) Iterates through the fields for this indexable and indexes any SearchField's or SearchFacet's.
org.apache.solr.common.SolrInputDocument	buildDocument(Indexable indexable, List<IndexField> fields, List<Locale> locales) Given a product, fields that relate to that product, and a list of locales and pricelists, builds a SolrInputDocument to be added to the Solr index.
Collection<org.apache.solr.common.SolrInputDocument>	buildIncrementalIndex(List<? extends Indexable> indexables, org.apache.solr.client.solrj.SolrClient solrServer) Builds a set of Indexables against the given SolrServer
void	buildIndex() Handles all the document building for the current index rebuild.
void	commit(org.apache.solr.client.solrj.SolrClient server) Allows a commit to be called.
void	commit(org.apache.solr.client.solrj.SolrClient server, boolean softCommit, boolean waitSearcher, boolean waitFlush) This allows an external caller to force a commit to the SolrClient.
void	deleteAllDocuments(org.apache.solr.client.solrj.SolrClient server)
void	deleteAllNamespaceDocuments(org.apache.solr.client.solrj.SolrClient server)
void	deleteByQuery(String deleteQuery)
void	executeSolrIndexOperation(SolrIndexOperation operation) Executes the given operation in the correct method order
List<Sku>	filterIndexableSkus(List<Sku> skus) Filters out Skus that shouldn't be indexed if any of the following are true:
List<Locale>	getAllLocales()
SolrIndexOperation	getReindexOperation() Creates the SolrIndexOperation for rebuilding the current index, used by buildIndex().
void	logDeleteQuery(String deleteQuery)
void	logDocuments(Collection<org.apache.solr.common.SolrInputDocument> documents) Prints out the docs to the trace logger
void	optimizeIndex(org.apache.solr.client.solrj.SolrClient server) Triggers the Solr optimize index function on the given server.
void	performCachedOperation(SolrIndexCachedOperation.CacheOperation cacheOperation) SolrIndexService exposes #buildIncrementalIndex(int, int, boolean).
void	postBuildIndex() Executed after we do any indexing when rebuilding the current index.
void	preBuildIndex() Executed before we do any indexing when rebuilding the index.
void	rebuildIndex() Executes a full rebuild of the Solr index.
void	restoreState(Object[] pack) Restores state that was saved prior to indexing that might have been altered.
Object[]	saveState() Saves some global context that might be altered during indexing.

Method Detail

rebuildIndex

void rebuildIndex()
           throws ServiceException,
                  IOException

Executes a full rebuild of the Solr index. This will rebuild the index on a separate core/collection and then swap out the active core/collection with the new version of the index (essentially replacing all documents that are currently in the index).

The order of methods that are apart of rebuilding the entire index:

1. preBuildIndex()

2. buildIndex()

3. postBuildIndex()

Throws:

IOException

ServiceException

preBuildIndex

void preBuildIndex()
            throws ServiceException

Executed before we do any indexing when rebuilding the index. Usually this handles deleting the current index. This is called at the beginning of rebuildIndex()

Throws:

ServiceException

buildIndex

void buildIndex()
         throws IOException,
                ServiceException

Handles all the document building for the current index rebuild. This is where all of the SolrIndexOperation's need to be created, executed and the documents built and added to the Solr index

This is the method that should be overridden to specify which operations should be run to build the correct index.

Throws:

IOException

ServiceException

See Also:

#rebuildIndex()}, #preBuildIndex()}

postBuildIndex

void postBuildIndex()
             throws IOException,
                    ServiceException

Executed after we do any indexing when rebuilding the current index. Usually this handles optimizing the index and swapping the cores.

Throws:

IOException

ServiceException

getReindexOperation

SolrIndexOperation getReindexOperation()

Creates the SolrIndexOperation for rebuilding the current index, used by buildIndex(). This is the primary index operation used to rebuild the index.

Returns:

a SolrIndexOperation capable of rebuilding the current index

executeSolrIndexOperation

void executeSolrIndexOperation(SolrIndexOperation operation)
                        throws ServiceException,
                               IOException

Executes the given operation in the correct method order

Parameters:

operation - the SolrIndexOperation that is to be executed

Throws:

ServiceException

IOException

buildIncrementalIndex

Collection<org.apache.solr.common.SolrInputDocument> buildIncrementalIndex(List<? extends Indexable> indexables,
                                                                           org.apache.solr.client.solrj.SolrClient solrServer)
                                                                    throws ServiceException

Builds a set of Indexables against the given SolrServer

Parameters:

indexables - the list of items to index

solrServer - if non-null, adds and commits the indexed documents to the server. If this is null, this will simply return the documents that were built from indexables

Returns:

the SolrInputDocuments that were built from the given indexables

Throws:

ServiceException

saveState

Object[] saveState()

Saves some global context that might be altered during indexing.

Returns:

restoreState

void restoreState(Object[] pack)

Restores state that was saved prior to indexing that might have been altered.

Parameters:

pack -

See Also:

saveState()

optimizeIndex

void optimizeIndex(org.apache.solr.client.solrj.SolrClient server)
            throws ServiceException,
                   IOException

Triggers the Solr optimize index function on the given server. This is typically called at the end of a rebuildIndex()

Parameters:

server -

Throws:

ServiceException

IOException

commit

void commit(org.apache.solr.client.solrj.SolrClient server)
     throws ServiceException,
            IOException

Allows a commit to be called. By default, the details of the commit will depend on system properties, including: solr.index.commit - if false, then no commit will be performed. autoCommit (and autoSoftCommit) should be configured in Solr. solr.index.softCommit - indicates if a soft commit should be performed solr.index.waitSearcher - indicates if the process should wait for a searcher to be configured solr.index.waitFlush - indicates if the process should wait for a flush to disk

Parameters:

server -

Throws:

ServiceException

IOException

commit

void commit(org.apache.solr.client.solrj.SolrClient server,
            boolean softCommit,
            boolean waitSearcher,
            boolean waitFlush)
     throws ServiceException,
            IOException

This allows an external caller to force a commit to the SolrClient. See Solr Documentation for additional details. If using softCommit, you should ensure that a hardCommit is performed, either using autoCommit, or at the end of the commit process to flush the changes to the disk. Note that this method will force a commit even if solr.index.commit=false

Parameters:

server - - the SolrClient to update

softCommit - - soft commit is an efficient commit that does not write the data to the file system

waitSearcher - - whether or not to wait for a new searcher to be created

waitFlush - - whether or not to wait for a flush to disk.

Throws:

ServiceException

IOException

deleteAllNamespaceDocuments

void deleteAllNamespaceDocuments(org.apache.solr.client.solrj.SolrClient server)
                          throws ServiceException

Throws:

ServiceException

deleteAllDocuments

void deleteAllDocuments(org.apache.solr.client.solrj.SolrClient server)
                 throws ServiceException

Throws:

ServiceException

logDocuments

void logDocuments(Collection<org.apache.solr.common.SolrInputDocument> documents)

Prints out the docs to the trace logger

Parameters:

documents -

getAllLocales

List<Locale> getAllLocales()

Returns:

a list of all possible locale prefixes to consider

buildDocument

org.apache.solr.common.SolrInputDocument buildDocument(Indexable indexable,
                                                       List<IndexField> fields,
                                                       List<Locale> locales)

Given a product, fields that relate to that product, and a list of locales and pricelists, builds a SolrInputDocument to be added to the Solr index.

Parameters:

product -

fields -

locales -

Returns:

the document

performCachedOperation

void performCachedOperation(SolrIndexCachedOperation.CacheOperation cacheOperation)
                     throws ServiceException

SolrIndexService exposes #buildIncrementalIndex(int, int, boolean). By wrapping the call to this method inside of a SolrIndexCachedOperation.CacheOperation, a single cache will be used for all the contained calls to buildIncrementalIndex. Here's an example: {@code performCachedOperation(new SolrIndexCachedOperation.CacheOperation() {

Parameters:

cacheOperation - the block of code to perform using a single cache for best performance

Throws:

ServiceException

filterIndexableSkus

List<Sku> filterIndexableSkus(List<Sku> skus)

Filters out Skus that shouldn't be indexed if any of the following are true:

1. If it's inactive
2. If it's a default Sku and shouldn't be sold without product options
3. If it's a default Sku for a Product Bundle

Parameters:

skus -

Returns:

a new list based on the given set of skus that only contains Skus that should be indexed

attachIndexableDocumentFields

void attachIndexableDocumentFields(org.apache.solr.common.SolrInputDocument document,
                                   Indexable indexable,
                                   List<IndexField> fields,
                                   List<Locale> locales)

Iterates through the fields for this indexable and indexes any SearchField's or SearchFacet's.

Parameters:

document -

indexable -

fields -

locales -

deleteByQuery

void deleteByQuery(String deleteQuery)
            throws org.apache.solr.client.solrj.SolrServerException,
                   IOException

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

addDocuments

void addDocuments(Collection<org.apache.solr.common.SolrInputDocument> documents)
           throws IOException,
                  org.apache.solr.client.solrj.SolrServerException

Throws:

IOException

org.apache.solr.client.solrj.SolrServerException

logDeleteQuery

void logDeleteQuery(String deleteQuery)