de.hybris.platform.processing.distributed.simple.context

Class SimpleProcessCreationContext

java.lang.Object

de.hybris.platform.processing.distributed.simple.context.SimpleProcessCreationContext

All Implemented Interfaces:

DistributedProcessHandler.ProcessCreationContext

Direct Known Subclasses:

DefaultIndexerProcessCreationContext

public class SimpleProcessCreationContext
extends java.lang.Object
implements DistributedProcessHandler.ProcessCreationContext

Field Summary

Fields

Modifier and Type	Field and Description
protected SimpleAbstractDistributedProcessCreationData	creationData
protected ModelService	modelService

Constructor Summary

Constructors

Constructor and Description
SimpleProcessCreationContext(ModelService modelService, SimpleAbstractDistributedProcessCreationData creationData)

Method Summary

Modifier and Type	Method and Description
protected DistributedProcessModel	createDistributedProcessModel()
DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel>	createProcessModel()
protected java.lang.Class<? extends SimpleDistributedProcessModel>	getProcessModelClass()
java.util.stream.Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>>	initialBatches()
protected DistributedProcessHandler.ModelWithDependencies<BatchModel>	prepareBatch(SimpleBatchCreationData data)

Methods inherited from class java.lang.Object

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

Field Detail

modelService

protected final ModelService modelService

creationData

protected final SimpleAbstractDistributedProcessCreationData creationData

Constructor Detail

SimpleProcessCreationContext

public SimpleProcessCreationContext(ModelService modelService,
                                    SimpleAbstractDistributedProcessCreationData creationData)

Method Detail

createProcessModel

public DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel> createProcessModel()

Specified by:

createProcessModel in interface DistributedProcessHandler.ProcessCreationContext

createDistributedProcessModel

protected DistributedProcessModel createDistributedProcessModel()

getProcessModelClass

protected java.lang.Class<? extends SimpleDistributedProcessModel> getProcessModelClass()

initialBatches

public java.util.stream.Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>> initialBatches()

Specified by:

initialBatches in interface DistributedProcessHandler.ProcessCreationContext

prepareBatch

protected DistributedProcessHandler.ModelWithDependencies<BatchModel> prepareBatch(SimpleBatchCreationData data)