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

Class DefaultIndexerDistributedProcessHandler

java.lang.Object

de.hybris.platform.processing.distributed.simple.SimpleAbstractDistributedProcessHandler

de.hybris.platform.processing.distributed.simple.SimpleDistributedProcessHandler

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

All Implemented Interfaces:

DistributedProcessHandler

public class DefaultIndexerDistributedProcessHandler
extends SimpleDistributedProcessHandler

Implementation of DistributedProcessHandler for distributed indexing.

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHandler

DistributedProcessHandler.ModelWithDependencies<T extends ItemModel>, DistributedProcessHandler.ProcessCreationContext, DistributedProcessHandler.ProcessExecutionAnalysisContext, DistributedProcessHandler.ProcessInitializationContext

Field Summary

Fields inherited from class de.hybris.platform.processing.distributed.simple.SimpleDistributedProcessHandler

simpleBatchProcessor

Fields inherited from class de.hybris.platform.processing.distributed.simple.SimpleAbstractDistributedProcessHandler

distributedProcessService, flexibleSearchService, LOG, modelService, REMAINING_WORKLOAD, WORK_DONE

Constructor Summary

Constructors

Constructor and Description
DefaultIndexerDistributedProcessHandler(ModelService modelService, FlexibleSearchService flexibleSearchService, DistributedProcessService distributedProcessService, SimpleBatchProcessor simpleBatchProcessor)

Method Summary

Modifier and Type	Method and Description
protected SimpleProcessCreationContext	prepareProcessCreationContext(SimpleAbstractDistributedProcessCreationData processData)
protected BatchModel	prepareResultBatch()

Methods inherited from class de.hybris.platform.processing.distributed.simple.SimpleDistributedProcessHandler

processBatch

Methods inherited from class de.hybris.platform.processing.distributed.simple.SimpleAbstractDistributedProcessHandler

calculateProgress, createProcessCreationContext, createProcessExecutionAnalysisContext, createProcessInitializationContext, createResultBatch, onFinished

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHandler

getTypesWithDisabledUniquenessCheck, updateStatusInformation

Constructor Detail

DefaultIndexerDistributedProcessHandler

public DefaultIndexerDistributedProcessHandler(ModelService modelService,
                                               FlexibleSearchService flexibleSearchService,
                                               DistributedProcessService distributedProcessService,
                                               SimpleBatchProcessor simpleBatchProcessor)

Method Detail

prepareProcessCreationContext

protected SimpleProcessCreationContext prepareProcessCreationContext(SimpleAbstractDistributedProcessCreationData processData)

Overrides:

prepareProcessCreationContext in class SimpleAbstractDistributedProcessHandler

prepareResultBatch

protected BatchModel prepareResultBatch()

Overrides:

prepareResultBatch in class SimpleAbstractDistributedProcessHandler