de.hybris.platform.solrfacetsearch.indexer.impl

Class DefaultIndexer

java.lang.Object

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

All Implemented Interfaces:

Indexer

public class DefaultIndexer
extends java.lang.Object
implements Indexer

Default implementation of Indexer.

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	INDEXED_FIELDS_KEY
protected static java.lang.String	VALUE_PROVIDERS_KEY

Constructor Summary

Constructors

Constructor and Description
DefaultIndexer()

Method Summary

Modifier and Type	Method and Description
protected void	addCommonFields(SolrInputDocument document, IndexerBatchContext batchContext, ItemModel model)
protected void	addIndexedPropertyFields(InputDocument document, IndexerBatchContext batchContext, ItemModel model)
protected void	addIndexedPropertyFieldsForNewApi(InputDocument document, IndexerBatchContext batchContext, ItemModel model, java.util.Collection<IndexedProperty> indexedProperties, java.lang.String valueProviderId, ValueResolver<ItemModel> valueProvider)
protected void	addIndexedPropertyFieldsForOldApi(InputDocument document, IndexerBatchContext batchContext, ItemModel model, java.util.Collection<IndexedProperty> indexedProperties, java.lang.String valueProviderId, FieldValueProvider valueProvider)
protected void	addIndexedTypeFields(InputDocument document, IndexerBatchContext batchContext, ItemModel model)
protected void	addIndexedTypeFieldsForNewApi(InputDocument document, IndexerBatchContext batchContext, ItemModel model, java.lang.String typeValueProviderBeanId, TypeValueResolver<ItemModel> typeValueProvider)
protected void	addIndexedTypeFieldsForOldApi(InputDocument document, IndexerBatchContext batchContext, ItemModel model, java.lang.String typeValueProviderBeanId, IndexedTypeFieldsValuesProvider typeValueProvider)
protected SolrInputDocument	createInputDocument(ItemModel model, IndexConfig indexConfig, IndexedType indexedType)
protected SolrInputDocument	createInputDocument(ItemModel model, IndexConfig indexConfig, IndexedType indexedType, java.util.Collection<IndexedProperty> indexedProperties)
protected DefaultSolrInputDocument	createWrappedDocument(IndexerBatchContext batchContext, SolrInputDocument delegate)
protected DefaultSolrInputDocument	createWrappedDocumentForPartialUpdates(IndexerBatchContext batchContext, SolrInputDocument delegate, java.util.Set<java.lang.String> indexedPropertiesFields)
protected BeanFactory	getBeanFactory()
protected Exporter	getExporter(SolrServerMode serverMode)
FieldNameProvider	getFieldNameProvider()
protected IdentityProvider<ItemModel>	getIdentityProvider(IndexedType indexedType)
protected java.util.Set<java.lang.String>	getIndexedFields(IndexerBatchContext batchContext)
protected java.util.Set<java.lang.String>	getIndexedFields(Index index, SolrClient solrClient)
IndexerBatchContextFactory	getIndexerBatchContextFactory()
ModelService	getModelService()
RangeNameProvider	getRangeNameProvider()
SolrSearchProviderFactory	getSolrSearchProviderFactory()
TypeService	getTypeService()
protected java.lang.Object	getTypeValueProvider(java.lang.String beanName)
ValueProviderSelectionStrategy	getValueProviderSelectionStrategy()
protected void	handleError(IndexConfig indexConfig, IndexedType indexedType, java.lang.String message, java.lang.Exception error)
protected void	handleError(IndexConfig indexConfig, java.lang.String message, java.lang.Exception error)
java.util.Collection<SolrInputDocument>	indexItems(java.util.Collection<ItemModel> items, FacetSearchConfig facetSearchConfig, IndexedType indexedType) Method send items to indexer.
java.util.Collection<SolrInputDocument>	indexItems(java.util.Collection<ItemModel> items, FacetSearchConfig facetSearchConfig, IndexedType indexedType, java.util.Collection<IndexedProperty> indexedProperties) Method send items to indexer.
java.util.Collection<java.lang.String>	removeItems(java.util.Collection<ItemModel> items, FacetSearchConfig facetSearchConfig, IndexedType indexedType) Remove from index all items by indexer identifiers.
void	removeItemsByPk(java.util.Collection<PK> pks, FacetSearchConfig facetSearchConfig, IndexedType indexedType, Index index)
protected java.util.Map<java.lang.String,java.util.Collection<IndexedProperty>>	resolveValueProviders(IndexerBatchContext batchContext)
void	setBeanFactory(BeanFactory beanFactory)
void	setFieldNameProvider(FieldNameProvider fieldNameProvider)
void	setIndexerBatchContextFactory(IndexerBatchContextFactory indexerBatchContextFactory)
void	setModelService(ModelService modelService)
void	setRangeNameProvider(RangeNameProvider rangeNameProvider)
void	setSolrSearchProviderFactory(SolrSearchProviderFactory solrSearchProviderFactory)
void	setTypeService(TypeService typeService)
void	setValueProviderSelectionStrategy(ValueProviderSelectionStrategy valueProviderSelectionStrategy)
protected void	validateCommonRequiredParameters(ItemModel item, IndexConfig indexConfig, IndexedType indexedType)

Methods inherited from class java.lang.Object

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

Field Detail

VALUE_PROVIDERS_KEY

protected static final java.lang.String VALUE_PROVIDERS_KEY

See Also:

Constant Field Values

INDEXED_FIELDS_KEY

protected static final java.lang.String INDEXED_FIELDS_KEY

See Also:

Constant Field Values

Constructor Detail

DefaultIndexer

public DefaultIndexer()

Method Detail

getModelService

public ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)

getTypeService

public TypeService getTypeService()

setTypeService

public void setTypeService(TypeService typeService)

getSolrSearchProviderFactory

public SolrSearchProviderFactory getSolrSearchProviderFactory()

setSolrSearchProviderFactory

public void setSolrSearchProviderFactory(SolrSearchProviderFactory solrSearchProviderFactory)

getIndexerBatchContextFactory

public IndexerBatchContextFactory getIndexerBatchContextFactory()

setIndexerBatchContextFactory

public void setIndexerBatchContextFactory(IndexerBatchContextFactory indexerBatchContextFactory)

getFieldNameProvider

public FieldNameProvider getFieldNameProvider()

setFieldNameProvider

public void setFieldNameProvider(FieldNameProvider fieldNameProvider)

getRangeNameProvider

public RangeNameProvider getRangeNameProvider()

setRangeNameProvider

public void setRangeNameProvider(RangeNameProvider rangeNameProvider)

getValueProviderSelectionStrategy

public ValueProviderSelectionStrategy getValueProviderSelectionStrategy()

setValueProviderSelectionStrategy

public void setValueProviderSelectionStrategy(ValueProviderSelectionStrategy valueProviderSelectionStrategy)

getBeanFactory

protected BeanFactory getBeanFactory()

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

indexItems

public java.util.Collection<SolrInputDocument> indexItems(java.util.Collection<ItemModel> items,
                                                          FacetSearchConfig facetSearchConfig,
                                                          IndexedType indexedType)
                                                   throws IndexerException,
                                                          java.lang.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

java.lang.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 java.util.Collection<SolrInputDocument> indexItems(java.util.Collection<ItemModel> items,
                                                          FacetSearchConfig facetSearchConfig,
                                                          IndexedType indexedType,
                                                          java.util.Collection<IndexedProperty> indexedProperties)
                                                   throws IndexerException,
                                                          java.lang.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

java.lang.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(java.util.Collection<PK> pks,
                            FacetSearchConfig facetSearchConfig,
                            IndexedType indexedType,
                            Index index)
                     throws IndexerException,
                            java.lang.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:

java.lang.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 java.util.Collection<java.lang.String> removeItems(java.util.Collection<ItemModel> items,
                                                          FacetSearchConfig facetSearchConfig,
                                                          IndexedType indexedType)
                                                   throws IndexerException,
                                                          java.lang.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

java.lang.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.

handleError

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

Throws:

IndexerException

getIdentityProvider

protected IdentityProvider<ItemModel> getIdentityProvider(IndexedType indexedType)

getExporter

protected Exporter getExporter(SolrServerMode serverMode)

createInputDocument

protected SolrInputDocument createInputDocument(ItemModel model,
                                                IndexConfig indexConfig,
                                                IndexedType indexedType)
                                         throws FieldValueProviderException

Throws:

FieldValueProviderException

createInputDocument

protected SolrInputDocument createInputDocument(ItemModel model,
                                                IndexConfig indexConfig,
                                                IndexedType indexedType,
                                                java.util.Collection<IndexedProperty> indexedProperties)
                                         throws FieldValueProviderException

Throws:

FieldValueProviderException

validateCommonRequiredParameters

protected void validateCommonRequiredParameters(ItemModel item,
                                                IndexConfig indexConfig,
                                                IndexedType indexedType)

createWrappedDocument

protected DefaultSolrInputDocument createWrappedDocument(IndexerBatchContext batchContext,
                                                         SolrInputDocument delegate)

createWrappedDocumentForPartialUpdates

protected DefaultSolrInputDocument createWrappedDocumentForPartialUpdates(IndexerBatchContext batchContext,
                                                                          SolrInputDocument delegate,
                                                                          java.util.Set<java.lang.String> indexedPropertiesFields)

addCommonFields

protected void addCommonFields(SolrInputDocument document,
                               IndexerBatchContext batchContext,
                               ItemModel model)

addIndexedPropertyFields

protected void addIndexedPropertyFields(InputDocument document,
                                        IndexerBatchContext batchContext,
                                        ItemModel model)
                                 throws FieldValueProviderException

Throws:

FieldValueProviderException

addIndexedPropertyFieldsForOldApi

protected void addIndexedPropertyFieldsForOldApi(InputDocument document,
                                                 IndexerBatchContext batchContext,
                                                 ItemModel model,
                                                 java.util.Collection<IndexedProperty> indexedProperties,
                                                 java.lang.String valueProviderId,
                                                 FieldValueProvider valueProvider)
                                          throws FieldValueProviderException

Throws:

FieldValueProviderException

addIndexedPropertyFieldsForNewApi

protected void addIndexedPropertyFieldsForNewApi(InputDocument document,
                                                 IndexerBatchContext batchContext,
                                                 ItemModel model,
                                                 java.util.Collection<IndexedProperty> indexedProperties,
                                                 java.lang.String valueProviderId,
                                                 ValueResolver<ItemModel> valueProvider)
                                          throws FieldValueProviderException

Throws:

FieldValueProviderException

addIndexedTypeFields

protected void addIndexedTypeFields(InputDocument document,
                                    IndexerBatchContext batchContext,
                                    ItemModel model)
                             throws FieldValueProviderException

Throws:

FieldValueProviderException

addIndexedTypeFieldsForOldApi

protected void addIndexedTypeFieldsForOldApi(InputDocument document,
                                             IndexerBatchContext batchContext,
                                             ItemModel model,
                                             java.lang.String typeValueProviderBeanId,
                                             IndexedTypeFieldsValuesProvider typeValueProvider)
                                      throws FieldValueProviderException

Throws:

FieldValueProviderException

addIndexedTypeFieldsForNewApi

protected void addIndexedTypeFieldsForNewApi(InputDocument document,
                                             IndexerBatchContext batchContext,
                                             ItemModel model,
                                             java.lang.String typeValueProviderBeanId,
                                             TypeValueResolver<ItemModel> typeValueProvider)
                                      throws FieldValueProviderException

Throws:

FieldValueProviderException

resolveValueProviders

protected java.util.Map<java.lang.String,java.util.Collection<IndexedProperty>> resolveValueProviders(IndexerBatchContext batchContext)

getIndexedFields

protected java.util.Set<java.lang.String> getIndexedFields(IndexerBatchContext batchContext)
                                                    throws FieldValueProviderException

Throws:

FieldValueProviderException

getIndexedFields

protected java.util.Set<java.lang.String> getIndexedFields(Index index,
                                                           SolrClient solrClient)
                                                    throws SolrServerException,
                                                           java.io.IOException

Throws:

SolrServerException

java.io.IOException

handleError

protected void handleError(IndexConfig indexConfig,
                           java.lang.String message,
                           java.lang.Exception error)
                    throws FieldValueProviderException

Throws:

FieldValueProviderException

getTypeValueProvider

protected java.lang.Object getTypeValueProvider(java.lang.String beanName)