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

Class DefaultSnIndexerBatchStrategy

java.lang.Object

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 java.lang.Object
implements SnIndexerBatchStrategy, 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 identityProvider)
protected void	addIndexDocumentBatchOperationRequests(SnIndexerContext indexerContext, java.util.List<SnDocumentBatchOperationRequest> documentBatchOperationRequests, java.util.List<PK> pks, SnIdentityProvider 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	createIdentityProvider(SnIndexerContext indexerContext)
protected SnIndexerBatchResponse	createIndexerBatchResponse(SnIndexerContext indexerContext, java.lang.Integer totalItems, java.lang.Integer processedItems)
protected SnIndexerValueProvider	createValueProvider(java.lang.String valueProviderId)
protected java.util.Collection<DefaultSnIndexerBatchStrategy.ValueProviderWrapper>	createValueProviders(SnIndexerContext indexerContext)
protected SnIndexerBatchResponse	doExecute(SnIndexerContext indexerContext, java.lang.String indexerBatchId)
SnIndexerBatchResponse	execute(SnIndexerBatchRequest indexerBatchRequest)	Executes the indexer request.
protected void	executeAfterIndexBatchErrorListeners(SnIndexerContext indexerContext, java.util.List<SnIndexerBatchListener> listeners)
protected void	executeAfterIndexBatchListeners(SnIndexerContext indexerContext, java.util.List<SnIndexerBatchListener> listeners)
protected void	executeBeforeIndexBatchListeners(SnIndexerContext indexerContext, java.util.List<SnIndexerBatchListener> listeners)
protected org.springframework.context.ApplicationContext	getApplicationContext()
FlexibleSearchService	getFlexibleSearchService()
SnIndexerContextFactory	getSnIndexerContextFactory()
SnIndexService	getSnIndexService()
SnListenerFactory	getSnListenerFactory()
SnQualifierTypeFactory	getSnQualifierTypeFactory()
SnSearchProviderFactory	getSnSearchProviderFactory()
SnSessionService	getSnSessionService()
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setFlexibleSearchService(FlexibleSearchService flexibleSearchService)
void	setSnIndexerContextFactory(SnIndexerContextFactory snIndexerContextFactory)
void	setSnIndexService(SnIndexService snIndexService)
void	setSnListenerFactory(SnListenerFactory snListenerFactory)
void	setSnQualifierTypeFactory(SnQualifierTypeFactory snQualifierTypeFactory)
void	setSnSearchProviderFactory(SnSearchProviderFactory snSearchProviderFactory)
void	setSnSessionService(SnSessionService snSessionService)

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

execute

public SnIndexerBatchResponse execute(SnIndexerBatchRequest indexerBatchRequest)
                               throws SnIndexerException,
                                      java.lang.InterruptedException

Description copied from interface: SnIndexerBatchStrategy

Executes the indexer request.

Specified by:

execute in interface SnIndexerBatchStrategy

Returns:

the indexer batch response

Throws:

SnIndexerException - if an error occurs

java.lang.InterruptedException

executeBeforeIndexBatchListeners

protected void executeBeforeIndexBatchListeners(SnIndexerContext indexerContext,
                                                java.util.List<SnIndexerBatchListener> listeners)
                                         throws SnException

Throws:

SnException

executeAfterIndexBatchListeners

protected void executeAfterIndexBatchListeners(SnIndexerContext indexerContext,
                                               java.util.List<SnIndexerBatchListener> listeners)
                                        throws SnException

Throws:

SnException

executeAfterIndexBatchErrorListeners

protected void executeAfterIndexBatchErrorListeners(SnIndexerContext indexerContext,
                                                    java.util.List<SnIndexerBatchListener> listeners)

doExecute

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

Throws:

SnException

java.lang.InterruptedException

addIndexDocumentBatchOperationRequests

protected void addIndexDocumentBatchOperationRequests(SnIndexerContext indexerContext,
                                                      java.util.List<SnDocumentBatchOperationRequest> documentBatchOperationRequests,
                                                      java.util.List<PK> pks,
                                                      SnIdentityProvider 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 identityProvider)
                                                throws SnException,
                                                       java.lang.InterruptedException

Throws:

SnException

java.lang.InterruptedException

createIdentityProvider

protected SnIdentityProvider 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 createValueProvider(java.lang.String valueProviderId)
                                              throws SnIndexerException

Throws:

SnIndexerException

createIndexerBatchResponse

protected SnIndexerBatchResponse createIndexerBatchResponse(SnIndexerContext indexerContext,
                                                            java.lang.Integer totalItems,
                                                            java.lang.Integer processedItems)

getFlexibleSearchService

public FlexibleSearchService getFlexibleSearchService()

setFlexibleSearchService

public void setFlexibleSearchService(FlexibleSearchService flexibleSearchService)

getSnSessionService

public SnSessionService getSnSessionService()

setSnSessionService

public void setSnSessionService(SnSessionService snSessionService)

getSnIndexerContextFactory

public SnIndexerContextFactory getSnIndexerContextFactory()

setSnIndexerContextFactory

public void setSnIndexerContextFactory(SnIndexerContextFactory snIndexerContextFactory)

getSnIndexService

public SnIndexService getSnIndexService()

setSnIndexService

public void setSnIndexService(SnIndexService snIndexService)

getSnListenerFactory

public SnListenerFactory getSnListenerFactory()

setSnListenerFactory

public void setSnListenerFactory(SnListenerFactory snListenerFactory)

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