de.hybris.platform.solrfacetsearch.indexer.impl

Class DefaultIndexer

java.lang.Object

de.hybris.platform.solrfacetsearch.indexer.impl.DefaultIndexer

All Implemented Interfaces:

IndexSwappingCapableIndexer, Indexer

public class DefaultIndexer
extends Object
implements Indexer, IndexSwappingCapableIndexer

Default implementation of Indexer.

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.platform.solrfacetsearch.indexer.spi.Indexer

Indexer.CommitType

Constructor Summary

Constructors

Constructor and Description
DefaultIndexer()

Method Summary

Modifier and Type	Method and Description
void	commit(FacetSearchConfig facetSearchConfig, IndexedType indexedType, Index index, Indexer.CommitType commitType) Deprecated. Since 6.2.
protected BeanFactory	getBeanFactory()
protected Exporter	getExporter(SolrServerMode serverMode)
protected IdentityProvider<ItemModel>	getIdentityProvider(IndexedType indexedType)
SolrDocumentFactory	getSolrDocumentFactory()
SolrSearchProviderFactory	getSolrSearchProviderFactory()
protected void	handleError(IndexConfig indexConfig, IndexedType indexedType, String message, Exception error)
Collection<SolrInputDocument>	indexItems(Collection<ItemModel> items, FacetSearchConfig facetSearchConfig, IndexedType indexedType) Method send items to indexer.
Collection<SolrInputDocument>	indexItems(Collection<ItemModel> items, FacetSearchConfig facetSearchConfig, IndexedType indexedType, Collection<IndexedProperty> indexedProperties) Method send items to indexer.
void	optimize(FacetSearchConfig facetSearchConfig, IndexedType indexedType, Index index) Deprecated. Since 6.2.
void	removeAllItems(FacetSearchConfig facetSearchConfig, IndexedType indexedType, Index index) Deprecated. Since 6.2.
Collection<String>	removeItems(Collection<ItemModel> items, FacetSearchConfig facetSearchConfig, IndexedType indexedType) Remove from index all items by indexer identifiers.
void	removeItemsByPk(Collection<PK> pks, FacetSearchConfig facetSearchConfig, IndexedType indexedType, Index index)
void	removeItemsByQuery(FacetSearchConfig facetSearchConfig, IndexedType indexedType, Index index, String query) Deprecated. Since 6.2.
void	setBeanFactory(BeanFactory beanFactory)
void	setSolrDocumentFactory(SolrDocumentFactory solrDocumentFactory)
void	setSolrSearchProviderFactory(SolrSearchProviderFactory solrSearchProviderFactory)
void	swapIndexTypes(FacetSearchConfig facetSearchConfig, IndexedType stagedIndexedType) Deprecated. Since 6.2.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultIndexer

public DefaultIndexer()

Method Detail

getSolrSearchProviderFactory

public SolrSearchProviderFactory getSolrSearchProviderFactory()

setSolrSearchProviderFactory

public void setSolrSearchProviderFactory(SolrSearchProviderFactory solrSearchProviderFactory)

getSolrDocumentFactory

public SolrDocumentFactory getSolrDocumentFactory()

setSolrDocumentFactory

public void setSolrDocumentFactory(SolrDocumentFactory solrDocumentFactory)

getBeanFactory

protected BeanFactory getBeanFactory()

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

indexItems

public Collection<SolrInputDocument> indexItems(Collection<ItemModel> items,
                                                FacetSearchConfig facetSearchConfig,
                                                IndexedType indexedType)
                                         throws IndexerException,
                                                InterruptedException

Description copied from interface: Indexer

Method send items to indexer.

Specified by:

indexItems in interface Indexer

Parameters:

items - items for send to indexer in one transaction

facetSearchConfig - configuration of facet search

indexedType - indexed type definition

Returns:

list of items converted to solrDocuments

Throws:

IndexerException - if an error occurs during indexing

InterruptedException - if any thread interrupted the current thread before before it completed indexing. The interrupted status of the current thread is cleared when this exception is thrown.

indexItems

public Collection<SolrInputDocument> indexItems(Collection<ItemModel> items,
                                                FacetSearchConfig facetSearchConfig,
                                                IndexedType indexedType,
                                                Collection<IndexedProperty> indexedProperties)
                                         throws IndexerException,
                                                InterruptedException

Description copied from interface: Indexer

Method send items to indexer.

Specified by:

indexItems in interface Indexer

Parameters:

items - items for send to indexer in one transaction

facetSearchConfig - configuration of facet search

indexedType - indexed type definition

indexedProperties - the properties to index

Returns:

list of items converted to solrDocuments

Throws:

IndexerException - if an error occurs during indexing

InterruptedException - if any thread interrupted the current thread before before it completed indexing. The interrupted status of the current thread is cleared when this exception is thrown.

removeItemsByPk

public void removeItemsByPk(Collection<PK> pks,
                            FacetSearchConfig facetSearchConfig,
                            IndexedType indexedType,
                            Index index)
                     throws IndexerException,
                            InterruptedException

Specified by:

removeItemsByPk in interface Indexer

Parameters:

pks - - list of pks to be removed

facetSearchConfig - - the facet search configuration

indexedType - - the indexed type

Throws:

InterruptedException - if any thread interrupted the current thread before before it completed indexing. The interrupted status of the current thread is cleared when this exception is thrown.

IndexerException

removeItems

public Collection<String> removeItems(Collection<ItemModel> items,
                                      FacetSearchConfig facetSearchConfig,
                                      IndexedType indexedType)
                               throws IndexerException,
                                      InterruptedException

Description copied from interface: Indexer

Remove from index all items by indexer identifiers.

Specified by:

removeItems in interface Indexer

Parameters:

items - items for send to indexer in one transaction

facetSearchConfig - configuration of facet search

indexedType - indexed type definition

Returns:

collection of solrDocumentIds

Throws:

IndexerException - if an error occurs during indexing

InterruptedException - if any thread interrupted the current thread before before it completed indexing. The interrupted status of the current thread is cleared when this exception is thrown.

removeAllItems

@Deprecated
public void removeAllItems(FacetSearchConfig facetSearchConfig,
                                       IndexedType indexedType,
                                       Index index)
                                throws IndexerException

Deprecated. Since 6.2.

Description copied from interface: Indexer

Remove all items from index

Specified by:

removeAllItems in interface Indexer

Parameters:

facetSearchConfig - facet search configuration

indexedType - indexed type definition

index - index

Throws:

IndexerException

removeItemsByQuery

@Deprecated
public void removeItemsByQuery(FacetSearchConfig facetSearchConfig,
                                           IndexedType indexedType,
                                           Index index,
                                           String query)
                                    throws IndexerException

Deprecated. Since 6.2.

Description copied from interface: Indexer

Removes items from the index based on a specific query.

Specified by:

removeItemsByQuery in interface Indexer

Parameters:

facetSearchConfig - - the facet search configuration

indexedType - - the indexed type

index - - the index

query - - the raw query

Throws:

IndexerException

commit

@Deprecated
public void commit(FacetSearchConfig facetSearchConfig,
                               IndexedType indexedType,
                               Index index,
                               Indexer.CommitType commitType)
                        throws IndexerException

Deprecated. Since 6.2.

Description copied from interface: Indexer

Performs a commit on the given index. An hard commit makes sure that indexed documents are persisted and visible, a soft commit makes sure indexed documents are visible.

Specified by:

commit in interface Indexer

Parameters:

facetSearchConfig - - the facet search configuration

indexedType - - the indexed type

index - - the index

commitType - - the commit type

Throws:

IndexerException - if an error occurs during the commit

optimize

@Deprecated
public void optimize(FacetSearchConfig facetSearchConfig,
                                 IndexedType indexedType,
                                 Index index)
                          throws IndexerException

Deprecated. Since 6.2.

Description copied from interface: Indexer

Optimizes a given index. It does not wait for the operation to complete.

Specified by:

optimize in interface Indexer

Parameters:

facetSearchConfig - - the facet search configuration

indexedType - - the indexed type

index - - the index

Throws:

IndexerException - if an error occurs during the commit

swapIndexTypes

@Deprecated
public void swapIndexTypes(FacetSearchConfig facetSearchConfig,
                                       IndexedType stagedIndexedType)
                                throws IndexerException

Deprecated. Since 6.2.

Description copied from interface: IndexSwappingCapableIndexer

Performs swap operation for core names represented by the index types. The swap operation is performed for the SOLR server configured in the solrConfig.

Specified by:

swapIndexTypes in interface IndexSwappingCapableIndexer

Parameters:

facetSearchConfig - - configuration of faset search

stagedIndexedType - - index type of the temporary, staged core name

Throws:

IndexerException

handleError

protected void handleError(IndexConfig indexConfig,
                           IndexedType indexedType,
                           String message,
                           Exception error)
                    throws IndexerException

Throws:

IndexerException

getIdentityProvider

protected IdentityProvider<ItemModel> getIdentityProvider(IndexedType indexedType)

getExporter

protected Exporter getExporter(SolrServerMode serverMode)
                        throws IndexerException

Throws:

IndexerException