Class SimpleDistributedProcessInitializationContext
java.lang.Object
de.hybris.platform.processing.distributed.simple.context.SimpleDistributedProcessInitializationContext
- All Implemented Interfaces:
DistributedProcessHandler.ProcessInitializationContext
public class SimpleDistributedProcessInitializationContext
extends Object
implements DistributedProcessHandler.ProcessInitializationContext
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final FlexibleSearchServiceprotected final ModelServiceprotected final SimpleDistributedProcessModel -
Constructor Summary
ConstructorsConstructorDescriptionSimpleDistributedProcessInitializationContext(FlexibleSearchService flexibleSearchService, ModelService modelService, SimpleDistributedProcessModel process) -
Method Summary
Modifier and TypeMethodDescription
-
Field Details
-
flexibleSearchService
-
modelService
-
process
-
-
Constructor Details
-
SimpleDistributedProcessInitializationContext
public SimpleDistributedProcessInitializationContext(FlexibleSearchService flexibleSearchService, ModelService modelService, SimpleDistributedProcessModel process)
-
-
Method Details
-
initializeProcess
- Specified by:
initializeProcessin interfaceDistributedProcessHandler.ProcessInitializationContext
-
firstExecutionInputBatches
public Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>> firstExecutionInputBatches()- Specified by:
firstExecutionInputBatchesin interfaceDistributedProcessHandler.ProcessInitializationContext
-
prepareInputBatch
protected DistributedProcessHandler.ModelWithDependencies<BatchModel> prepareInputBatch(SimpleBatchModel batch)
-