Package de.hybris.platform.searchservices.indexer.service.impl

Class DefaultSnIndexerBatchStrategy

java.lang.Object

de.hybris.platform.searchservices.indexer.service.impl.AbstractSnIndexerBatchStrategy

de.hybris.platform.searchservices.indexer.service.impl.DefaultSnIndexerBatchStrategy

All Implemented Interfaces:

SnIndexerBatchStrategy, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class DefaultSnIndexerBatchStrategy
extends AbstractSnIndexerBatchStrategy
implements org.springframework.context.ApplicationContextAware

Default implementation for SnIndexerBatchStrategy.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	DefaultSnIndexerBatchStrategy.ValueProviderWrapper

Constructor Summary

Constructors

Constructor	Description
DefaultSnIndexerBatchStrategy()

Method Summary

Modifier and Type	Method	Description
protected void	addDeleteDocumentBatchOperationRequests(SnIndexerContext indexerContext, java.util.List<SnDocumentBatchOperationRequest> documentBatchOperationRequests, java.util.List<PK> pks, SnIdentityProvider<ItemModel> identityProvider)
protected void	addIndexDocumentBatchOperationRequests(SnIndexerContext indexerContext, java.util.List<SnDocumentBatchOperationRequest> documentBatchOperationRequests, java.util.List<PK> pks, SnIdentityProvider<ItemModel> identityProvider, SnDocumentOperationType operationType)
protected java.util.Map<java.lang.String,java.util.List<SnQualifier>>	collectAvailableQualifiers(SnIndexerContext indexerContext, SnIndexType indexType)
protected java.util.List<ItemModel>	collectItems(SnIndexerContext indexerContext, java.util.List<PK> pks)
protected SnIdentityProvider<ItemModel>	createIdentityProvider(SnIndexerContext indexerContext)
protected SnIndexerValueProvider<ItemModel>	createValueProvider(java.lang.String valueProviderId)
protected java.util.Collection<DefaultSnIndexerBatchStrategy.ValueProviderWrapper>	createValueProviders(SnIndexerContext indexerContext)
protected SnIndexerBatchResponse	doExecute(SnIndexerContext indexerContext, java.lang.String indexerBatchId)
protected org.springframework.context.ApplicationContext	getApplicationContext()
FlexibleSearchService	getFlexibleSearchService()
SnQualifierTypeFactory	getSnQualifierTypeFactory()
SnSearchProviderFactory	getSnSearchProviderFactory()
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setFlexibleSearchService(FlexibleSearchService flexibleSearchService)
void	setSnQualifierTypeFactory(SnQualifierTypeFactory snQualifierTypeFactory)
void	setSnSearchProviderFactory(SnSearchProviderFactory snSearchProviderFactory)

Methods inherited from class de.hybris.platform.searchservices.indexer.service.impl.AbstractSnIndexerBatchStrategy

createIndexerBatchResponse, execute, executeAfterIndexBatchErrorListeners, executeAfterIndexBatchListeners, executeBeforeIndexBatchListeners, getSnIndexerContextFactory, getSnListenerFactory, getSnSessionService, setSnIndexerContextFactory, setSnListenerFactory, setSnSessionService

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSnIndexerBatchStrategy

public DefaultSnIndexerBatchStrategy()

Method Detail

doExecute

protected SnIndexerBatchResponse doExecute(SnIndexerContext indexerContext,
                                           java.lang.String indexerBatchId)
                                    throws SnException,
                                           java.lang.InterruptedException

Specified by:

doExecute in class AbstractSnIndexerBatchStrategy

Throws:

SnException

java.lang.InterruptedException

addIndexDocumentBatchOperationRequests

protected void addIndexDocumentBatchOperationRequests(SnIndexerContext indexerContext,
                                                      java.util.List<SnDocumentBatchOperationRequest> documentBatchOperationRequests,
                                                      java.util.List<PK> pks,
                                                      SnIdentityProvider<ItemModel> identityProvider,
                                                      SnDocumentOperationType operationType)
                                               throws SnException,
                                                      java.lang.InterruptedException

Throws:

SnException

java.lang.InterruptedException

addDeleteDocumentBatchOperationRequests

protected void addDeleteDocumentBatchOperationRequests(SnIndexerContext indexerContext,
                                                       java.util.List<SnDocumentBatchOperationRequest> documentBatchOperationRequests,
                                                       java.util.List<PK> pks,
                                                       SnIdentityProvider<ItemModel> identityProvider)
                                                throws SnException,
                                                       java.lang.InterruptedException

Throws:

SnException

java.lang.InterruptedException

createIdentityProvider

protected SnIdentityProvider<ItemModel> createIdentityProvider(SnIndexerContext indexerContext)
                                                        throws SnIndexerException

Throws:

SnIndexerException

collectItems

protected java.util.List<ItemModel> collectItems(SnIndexerContext indexerContext,
                                                 java.util.List<PK> pks)

createValueProviders

protected java.util.Collection<DefaultSnIndexerBatchStrategy.ValueProviderWrapper> createValueProviders(SnIndexerContext indexerContext)
                                                                                                 throws SnIndexerException

Throws:

SnIndexerException

collectAvailableQualifiers

protected java.util.Map<java.lang.String,java.util.List<SnQualifier>> collectAvailableQualifiers(SnIndexerContext indexerContext,
                                                                                                       SnIndexType indexType)

createValueProvider

protected SnIndexerValueProvider<ItemModel> createValueProvider(java.lang.String valueProviderId)
                                                         throws SnIndexerException

Throws:

SnIndexerException

getFlexibleSearchService

public FlexibleSearchService getFlexibleSearchService()

setFlexibleSearchService

public void setFlexibleSearchService(FlexibleSearchService flexibleSearchService)

getSnSearchProviderFactory

public SnSearchProviderFactory getSnSearchProviderFactory()

setSnSearchProviderFactory

public void setSnSearchProviderFactory(SnSearchProviderFactory snSearchProviderFactory)

getSnQualifierTypeFactory

public SnQualifierTypeFactory getSnQualifierTypeFactory()

setSnQualifierTypeFactory

public void setSnQualifierTypeFactory(SnQualifierTypeFactory snQualifierTypeFactory)

getApplicationContext

protected org.springframework.context.ApplicationContext getApplicationContext()

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware