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

Class DefaultSnIndexerStrategy

java.lang.Object

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

All Implemented Interfaces:

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

public class DefaultSnIndexerStrategy
extends java.lang.Object
implements SnIndexerStrategy, org.springframework.context.ApplicationContextAware

Default implementation for SnIndexerStrategy.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	DefaultSnIndexerStrategy.IndexerBatch
protected static class	DefaultSnIndexerStrategy.IndexerBatchGroup
protected static class	DefaultSnIndexerStrategy.IndexerBatchWrapper

Field Summary

Fields

Modifier and Type	Field	Description
protected static int	DEFAULT_INDEXER_THREAD_POOL_SIZE
protected static int	DEFAULT_MAX_INDEXER_BATCH_RETRIES
protected static int	DEFAULT_MAX_INDEXER_BATCH_SIZE
protected static int	DEFAULT_MAX_INDEXER_RETRIES

Constructor Summary

Constructors

Constructor	Description
DefaultSnIndexerStrategy()

Method Summary

Modifier and Type	Method	Description
protected DefaultSnIndexerStrategy.IndexerBatchGroup	buildIndexerBatchGroup(SnIndexerContext indexerContext, SnDocumentOperationType documentOperationType, java.util.List<PK> indexerItemSourcePks, int batchIndex, int maxBatchSize)
protected DefaultSnIndexerStrategy.IndexerBatchGroup	buildIndexerBatchGroup(SnIndexerContext indexerContext, java.util.List<SnIndexerItemSourceOperation> batchIndexerItemSourceOperations, int batchIndex, int batchSize)
protected java.util.List<DefaultSnIndexerStrategy.IndexerBatchGroup>	buildIndexerBatchGroups(SnIndexerContext indexerContext)
protected java.lang.String	buildIndexerBatchId(int batchIndex)
protected java.util.concurrent.ExecutorService	createIndexerBatchExecutor(int threadPoolSize)
protected SnIndexerBatchRunnable	createIndexerBatchRunnable(SnIndexerContext indexerContext, java.util.List<SnIndexerItemSourceOperation> indexerItemSourceOperations, java.lang.String indexerBatchId)
protected SnIndexerResponse	createIndexerResponse(SnIndexerContext indexerContext, java.lang.Integer totalItems, java.lang.Integer processedItems)
protected SnIndexerResponse	doExecute(SnIndexerContext indexerContext, java.util.List<DefaultSnIndexerStrategy.IndexerBatchGroup> indexerBatchGroups)
SnIndexerResponse	execute(SnIndexerRequest indexerRequest)	Executes the indexer batch request.
protected void	executeAfterIndexErrorListeners(SnIndexerContext indexerContext, java.util.List<SnIndexerListener> listeners)
protected void	executeAfterIndexListeners(SnIndexerContext indexerContext, java.util.List<SnIndexerListener> listeners)
protected void	executeBeforeIndexListeners(SnIndexerContext indexerContext, java.util.List<SnIndexerListener> listeners)
protected java.lang.String	extractErrorMessage(java.lang.Exception exception)
protected org.springframework.context.ApplicationContext	getApplicationContext()
java.lang.String	getIndexerBatchRunnableId()
SnIndexerContextFactory	getSnIndexerContextFactory()
SnIndexService	getSnIndexService()
SnListenerFactory	getSnListenerFactory()
SnSearchProviderFactory	getSnSearchProviderFactory()
SnSessionService	getSnSessionService()
protected java.util.List<SnIndexerItemSourceOperation>	joinAndDedupIndexerItemSourceOperations(SnIndexerContext indexerContext)
protected void	runIndexerBatches(SnIndexerContext indexerContext, java.util.concurrent.ExecutorCompletionService<java.lang.String> completionService, int retriesLeft, java.util.List<DefaultSnIndexerStrategy.IndexerBatchWrapper> batches, java.util.List<DefaultSnIndexerStrategy.IndexerBatchWrapper> completedBatches)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setIndexerBatchRunnableId(java.lang.String batchRunnableBeanId)
void	setSnIndexerContextFactory(SnIndexerContextFactory snIndexerContextFactory)
void	setSnIndexService(SnIndexService snIndexService)
void	setSnListenerFactory(SnListenerFactory snListenerFactory)
void	setSnSearchProviderFactory(SnSearchProviderFactory snSearchProviderFactory)
void	setSnSessionService(SnSessionService snSessionService)
protected void	updateIndexerOperationStatusQuietly(SnIndexerContext indexerContext, SnIndexerOperationStatus status, java.lang.Exception exception)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_INDEXER_THREAD_POOL_SIZE

protected static final int DEFAULT_INDEXER_THREAD_POOL_SIZE

See Also:

Constant Field Values

DEFAULT_MAX_INDEXER_BATCH_SIZE

protected static final int DEFAULT_MAX_INDEXER_BATCH_SIZE

See Also:

Constant Field Values

DEFAULT_MAX_INDEXER_BATCH_RETRIES

protected static final int DEFAULT_MAX_INDEXER_BATCH_RETRIES

See Also:

Constant Field Values

DEFAULT_MAX_INDEXER_RETRIES

protected static final int DEFAULT_MAX_INDEXER_RETRIES

See Also:

Constant Field Values

Constructor Detail

DefaultSnIndexerStrategy

public DefaultSnIndexerStrategy()

Method Detail

execute

public SnIndexerResponse execute(SnIndexerRequest indexerRequest)
                          throws SnIndexerException

Description copied from interface: SnIndexerStrategy

Executes the indexer batch request.

Specified by:

execute in interface SnIndexerStrategy

Parameters:

indexerRequest - - the indexer request

Returns:

the indexer response

Throws:

SnIndexerException - if an error occurs

updateIndexerOperationStatusQuietly

protected void updateIndexerOperationStatusQuietly(SnIndexerContext indexerContext,
                                                   SnIndexerOperationStatus status,
                                                   java.lang.Exception exception)

extractErrorMessage

protected java.lang.String extractErrorMessage(java.lang.Exception exception)

executeBeforeIndexListeners

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

Throws:

SnException

executeAfterIndexListeners

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

Throws:

SnException

executeAfterIndexErrorListeners

protected void executeAfterIndexErrorListeners(SnIndexerContext indexerContext,
                                               java.util.List<SnIndexerListener> listeners)

buildIndexerBatchGroups

protected java.util.List<DefaultSnIndexerStrategy.IndexerBatchGroup> buildIndexerBatchGroups(SnIndexerContext indexerContext)
                                                                                      throws SnIndexerException

Throws:

SnIndexerException

joinAndDedupIndexerItemSourceOperations

protected java.util.List<SnIndexerItemSourceOperation> joinAndDedupIndexerItemSourceOperations(SnIndexerContext indexerContext)
                                                                                        throws SnIndexerException

Throws:

SnIndexerException

buildIndexerBatchGroup

protected DefaultSnIndexerStrategy.IndexerBatchGroup buildIndexerBatchGroup(SnIndexerContext indexerContext,
                                                                            java.util.List<SnIndexerItemSourceOperation> batchIndexerItemSourceOperations,
                                                                            int batchIndex,
                                                                            int batchSize)

buildIndexerBatchGroup

protected DefaultSnIndexerStrategy.IndexerBatchGroup buildIndexerBatchGroup(SnIndexerContext indexerContext,
                                                                            SnDocumentOperationType documentOperationType,
                                                                            java.util.List<PK> indexerItemSourcePks,
                                                                            int batchIndex,
                                                                            int maxBatchSize)

buildIndexerBatchId

protected java.lang.String buildIndexerBatchId(int batchIndex)

doExecute

protected SnIndexerResponse doExecute(SnIndexerContext indexerContext,
                                      java.util.List<DefaultSnIndexerStrategy.IndexerBatchGroup> indexerBatchGroups)
                               throws SnIndexerException

Throws:

SnIndexerException

createIndexerBatchExecutor

protected java.util.concurrent.ExecutorService createIndexerBatchExecutor(int threadPoolSize)

createIndexerBatchRunnable

protected SnIndexerBatchRunnable createIndexerBatchRunnable(SnIndexerContext indexerContext,
                                                            java.util.List<SnIndexerItemSourceOperation> indexerItemSourceOperations,
                                                            java.lang.String indexerBatchId)
                                                     throws SnIndexerException

Throws:

SnIndexerException

runIndexerBatches

protected void runIndexerBatches(SnIndexerContext indexerContext,
                                 java.util.concurrent.ExecutorCompletionService<java.lang.String> completionService,
                                 int retriesLeft,
                                 java.util.List<DefaultSnIndexerStrategy.IndexerBatchWrapper> batches,
                                 java.util.List<DefaultSnIndexerStrategy.IndexerBatchWrapper> completedBatches)
                          throws SnIndexerException

Throws:

SnIndexerException

createIndexerResponse

protected SnIndexerResponse createIndexerResponse(SnIndexerContext indexerContext,
                                                  java.lang.Integer totalItems,
                                                  java.lang.Integer processedItems)

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)

getIndexerBatchRunnableId

public java.lang.String getIndexerBatchRunnableId()

setIndexerBatchRunnableId

public void setIndexerBatchRunnableId(java.lang.String batchRunnableBeanId)

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