Class DistributedIndexerStrategy
java.lang.Object
de.hybris.platform.solrfacetsearch.indexer.strategies.impl.AbstractIndexerStrategy
de.hybris.platform.solrfacetsearch.indexer.strategies.impl.DistributedIndexerStrategy
- All Implemented Interfaces:
IndexerStrategy
Implementation of
IndexerStrategy that distributes work across cluster nodes.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected CollectionBasedCreationDatabuildIndexerCreationData(IndexerContext indexerContext) protected SolrIndexerDistributedProcessModelcreateDistributedIndexerProcess(CollectionBasedCreationData indexerProcessData, IndexerContext indexerContext) protected voiddoExecute(IndexerContext indexerContext) protected RevertibleUpdatevoidsetDistributedProcessService(DistributedProcessService distributedProcessService) voidsetModelService(ModelService modelService) protected voidwaitForDistributedIndexer(String processCode) 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
-
DistributedIndexerStrategy
public DistributedIndexerStrategy()
-
-
Method Details
-
doExecute
- Specified by:
doExecutein classAbstractIndexerStrategy- Throws:
IndexerException
-
markThreadAsSuspendable
-
buildIndexerCreationData
-
createDistributedIndexerProcess
protected SolrIndexerDistributedProcessModel createDistributedIndexerProcess(CollectionBasedCreationData indexerProcessData, IndexerContext indexerContext) -
waitForDistributedIndexer
protected void waitForDistributedIndexer(String processCode) throws IndexerException, InterruptedException - Throws:
IndexerExceptionInterruptedException
-
getDistributedProcessService
-
setDistributedProcessService
-
getModelService
-
setModelService
-