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

Direct Known Subclasses:

BackofficeIndexerStrategy

public class DefaultIndexerStrategy
extends AbstractIndexerStrategy

Default implementation of IndexerStrategy.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static 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, java.util.List<PK> workerPks)
protected java.util.concurrent.ExecutorService	createIndexerWorkersPool(int numberOfThreads)
protected void	doExecute(IndexerContext indexerContext)
IndexerWorkerFactory	getIndexerWorkerFactory()
protected RevertibleUpdate	markThreadAsSuspendable()
protected void	runWorkers(IndexerContext indexerContext, java.util.concurrent.ExecutorCompletionService<java.lang.Integer> completionService, java.util.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, registerOrUpdateNonSuspendableThread, removeLocalSessionContext, resolveIndex, resolveIndexedProperties, resolveIndexerHints, resolvePks, resolveSessionCurrency, resolveSessionLanguage, resolveSessionUser, resolveTenantId, revertOperationInfo, 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

markThreadAsSuspendable

protected RevertibleUpdate markThreadAsSuspendable()

runWorkers

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

Throws:

IndexerException

createIndexerWorkersPool

protected java.util.concurrent.ExecutorService createIndexerWorkersPool(int numberOfThreads)

createIndexerWorker

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

Throws:

IndexerException

getIndexerWorkerFactory

public IndexerWorkerFactory getIndexerWorkerFactory()

setIndexerWorkerFactory

public void setIndexerWorkerFactory(IndexerWorkerFactory indexerWorkerFactory)