de.hybris.platform.solrfacetsearch.indexer.strategies.impl

Class DefaultIndexerStrategy

java.lang.Object

de.hybris.platform.solrfacetsearch.indexer.strategies.impl.AbstractIndexerStrategy

de.hybris.platform.solrfacetsearch.indexer.strategies.impl.DefaultIndexerStrategy

All Implemented Interfaces:

IndexerStrategy

public class DefaultIndexerStrategy
extends AbstractIndexerStrategy

Default implementation of IndexerStrategy.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	DefaultIndexerStrategy.IndexerWorkerWrapper

Constructor Summary

Constructors

Constructor and Description
DefaultIndexerStrategy()

Method Summary

Modifier and Type	Method and Description
protected IndexerWorker	createIndexerWorker(IndexerContext indexerContext, long workerNumber, List<PK> workerPks)
protected ExecutorService	createIndexerWorkersPool(int numberOfThreads)
protected void	doExecute(IndexerContext indexerContext)
IndexerWorkerFactory	getIndexerWorkerFactory()
protected void	runWorkers(IndexerContext indexerContext, ExecutorCompletionService<Integer> completionService, List<DefaultIndexerStrategy.IndexerWorkerWrapper> workers, int retriesLeft)
void	setIndexerWorkerFactory(IndexerWorkerFactory indexerWorkerFactory)

Methods inherited from class de.hybris.platform.solrfacetsearch.indexer.strategies.impl.AbstractIndexerStrategy

createIndexerQuery, createLocalSessionContext, doExecute, execute, executeIndexerQuery, getCommonI18NService, getFacetSearchConfig, getFlexibleSearchQuerySpecFactory, getIndex, getIndexedProperties, getIndexedType, getIndexerContextFactory, getIndexerHints, getIndexerQueriesExecutor, getIndexOperation, getIndexOperationIdGenerator, getPks, getSessionService, getSolrIndexService, getSolrSearchProviderFactory, getTenantService, getUserService, logStrategyError, logStrategyStart, logStrategySuccess, removeLocalSessionContext, resolveIndex, resolveIndexedProperties, resolveIndexerHints, resolvePks, resolveSessionCurrency, resolveSessionLanguage, resolveSessionUser, resolveTenantId, setCommonI18NService, setFacetSearchConfig, setFlexibleSearchQuerySpecFactory, setIndex, setIndexedProperties, setIndexedType, setIndexerContextFactory, setIndexerHints, setIndexerQueriesExecutor, setIndexOperation, setIndexOperationIdGenerator, setPks, setSessionService, setSolrIndexService, setSolrSearchProviderFactory, setTenantService, setUserService, validateRequiredFields

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultIndexerStrategy

public DefaultIndexerStrategy()

Method Detail

doExecute

protected void doExecute(IndexerContext indexerContext)
                  throws IndexerException

Specified by:

doExecute in class AbstractIndexerStrategy

Throws:

IndexerException

runWorkers

protected void runWorkers(IndexerContext indexerContext,
                          ExecutorCompletionService<Integer> completionService,
                          List<DefaultIndexerStrategy.IndexerWorkerWrapper> workers,
                          int retriesLeft)
                   throws IndexerException

Throws:

IndexerException

createIndexerWorkersPool

protected ExecutorService createIndexerWorkersPool(int numberOfThreads)

createIndexerWorker

protected IndexerWorker createIndexerWorker(IndexerContext indexerContext,
                                            long workerNumber,
                                            List<PK> workerPks)
                                     throws IndexerException

Throws:

IndexerException

getIndexerWorkerFactory

public IndexerWorkerFactory getIndexerWorkerFactory()

setIndexerWorkerFactory

public void setIndexerWorkerFactory(IndexerWorkerFactory indexerWorkerFactory)