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

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

public class DistributedIndexerStrategy
extends AbstractIndexerStrategy

Implementation of IndexerStrategy that distributes work across cluster nodes.

Constructor Summary

Constructors

Constructor and Description
DistributedIndexerStrategy()

Method Summary

Modifier and Type	Method and Description
protected void	doExecute(IndexerContext indexerContext)
DistributedProcessService	getDistributedProcessService()
ModelService	getModelService()
void	setDistributedProcessService(DistributedProcessService distributedProcessService)
void	setModelService(ModelService modelService)
protected void	waitForDistributedIndexer(String processCode)

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

DistributedIndexerStrategy

public DistributedIndexerStrategy()

Method Detail

doExecute

protected void doExecute(IndexerContext indexerContext)
                  throws IndexerException

Specified by:

doExecute in class AbstractIndexerStrategy

Throws:

IndexerException

waitForDistributedIndexer

protected void waitForDistributedIndexer(String processCode)
                                  throws IndexerException,
                                         InterruptedException

Throws:

IndexerException

InterruptedException

getDistributedProcessService

public DistributedProcessService getDistributedProcessService()

setDistributedProcessService

public void setDistributedProcessService(DistributedProcessService distributedProcessService)

getModelService

public ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)