Class SimpleDistributedProcessInitializationContext
- java.lang.Object
-
- de.hybris.platform.processing.distributed.simple.context.SimpleDistributedProcessInitializationContext
-
- All Implemented Interfaces:
DistributedProcessHandler.ProcessInitializationContext
public class SimpleDistributedProcessInitializationContext extends java.lang.Object implements DistributedProcessHandler.ProcessInitializationContext
-
-
Field Summary
Fields Modifier and Type Field Description protected FlexibleSearchServiceflexibleSearchServiceprotected ModelServicemodelServiceprotected SimpleDistributedProcessModelprocess
-
Constructor Summary
Constructors Constructor Description SimpleDistributedProcessInitializationContext(FlexibleSearchService flexibleSearchService, ModelService modelService, SimpleDistributedProcessModel process)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.stream.Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>>firstExecutionInputBatches()DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel>initializeProcess()protected DistributedProcessHandler.ModelWithDependencies<BatchModel>prepareInputBatch(SimpleBatchModel batch)
-
-
-
Field Detail
-
flexibleSearchService
protected final FlexibleSearchService flexibleSearchService
-
modelService
protected final ModelService modelService
-
process
protected final SimpleDistributedProcessModel process
-
-
Constructor Detail
-
SimpleDistributedProcessInitializationContext
public SimpleDistributedProcessInitializationContext(FlexibleSearchService flexibleSearchService, ModelService modelService, SimpleDistributedProcessModel process)
-
-
Method Detail
-
initializeProcess
public DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel> initializeProcess()
- Specified by:
initializeProcessin interfaceDistributedProcessHandler.ProcessInitializationContext
-
firstExecutionInputBatches
public java.util.stream.Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>> firstExecutionInputBatches()
- Specified by:
firstExecutionInputBatchesin interfaceDistributedProcessHandler.ProcessInitializationContext
-
prepareInputBatch
protected DistributedProcessHandler.ModelWithDependencies<BatchModel> prepareInputBatch(SimpleBatchModel batch)
-
-