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 CollectionBasedCreationData	buildIndexerCreationData(IndexerContext indexerContext)
protected SolrIndexerDistributedProcessModel	createDistributedIndexerProcess(CollectionBasedCreationData indexerProcessData, IndexerContext indexerContext)
protected void	doExecute(IndexerContext indexerContext)
DistributedProcessService	getDistributedProcessService()
ModelService	getModelService()
protected RevertibleUpdate	markThreadAsSuspendable()
void	setDistributedProcessService(DistributedProcessService distributedProcessService)
void	setModelService(ModelService modelService)
protected void	waitForDistributedIndexer(java.lang.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, 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

DistributedIndexerStrategy

public DistributedIndexerStrategy()

Method Detail

doExecute

protected void doExecute(IndexerContext indexerContext)
                  throws IndexerException

Specified by:

doExecute in class AbstractIndexerStrategy

Throws:

IndexerException

markThreadAsSuspendable

protected RevertibleUpdate markThreadAsSuspendable()

buildIndexerCreationData

protected CollectionBasedCreationData buildIndexerCreationData(IndexerContext indexerContext)

createDistributedIndexerProcess

protected SolrIndexerDistributedProcessModel createDistributedIndexerProcess(CollectionBasedCreationData indexerProcessData,
                                                                             IndexerContext indexerContext)

waitForDistributedIndexer

protected void waitForDistributedIndexer(java.lang.String processCode)
                                  throws IndexerException,
                                         java.lang.InterruptedException

Throws:

IndexerException

java.lang.InterruptedException

getDistributedProcessService

public DistributedProcessService getDistributedProcessService()

setDistributedProcessService

public void setDistributedProcessService(DistributedProcessService distributedProcessService)

getModelService

public ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)