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
Default implementation of
IndexerStrategy.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected static class -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected IndexerWorkercreateIndexerWorker(IndexerContext indexerContext, long workerNumber, List<PK> workerPks) protected ExecutorServicecreateIndexerWorkersPool(int numberOfThreads) protected voiddoExecute(IndexerContext indexerContext) protected RevertibleUpdateprotected voidrunWorkers(IndexerContext indexerContext, ExecutorCompletionService<Integer> completionService, List<DefaultIndexerStrategy.IndexerWorkerWrapper> workers, int retriesLeft) voidsetIndexerWorkerFactory(IndexerWorkerFactory indexerWorkerFactory) Methods inherited from class de.hybris.platform.solrfacetsearch.indexer.strategies.impl.AbstractIndexerStrategy
createIndexerQuery, createLocalSessionContext, doExecute, execute, executeIndexerQuery, getCommonI18NService, getFacetSearchConfig, getFlexibleSearchQuerySpecFactory, getFlexibleSearchService, 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, resolveSessionUseReadOnlyDataSource, resolveTenantId, revertOperationInfo, setCommonI18NService, setFacetSearchConfig, setFlexibleSearchQuerySpecFactory, setFlexibleSearchService, setIndex, setIndexedProperties, setIndexedType, setIndexerContextFactory, setIndexerHints, setIndexerQueriesExecutor, setIndexOperation, setIndexOperationIdGenerator, setPks, setSessionService, setSolrIndexService, setSolrSearchProviderFactory, setTenantService, setUserService, validateRequiredFields
-
Constructor Details
-
DefaultIndexerStrategy
public DefaultIndexerStrategy()
-
-
Method Details
-
doExecute
- Specified by:
doExecutein classAbstractIndexerStrategy- Throws:
IndexerException
-
markThreadAsSuspendable
-
runWorkers
protected void runWorkers(IndexerContext indexerContext, ExecutorCompletionService<Integer> completionService, List<DefaultIndexerStrategy.IndexerWorkerWrapper> workers, int retriesLeft) throws IndexerException - Throws:
IndexerException
-
createIndexerWorkersPool
-
createIndexerWorker
protected IndexerWorker createIndexerWorker(IndexerContext indexerContext, long workerNumber, List<PK> workerPks) throws IndexerException - Throws:
IndexerException
-
getIndexerWorkerFactory
-
setIndexerWorkerFactory
-