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

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 and Description
protected FlexibleSearchService	flexibleSearchService
protected ModelService	modelService
protected SimpleDistributedProcessModel	process

Constructor Summary

Constructors

Constructor and Description
SimpleDistributedProcessInitializationContext(FlexibleSearchService flexibleSearchService, ModelService modelService, SimpleDistributedProcessModel process)

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>>	firstExecutionInputBatches()
DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel>	initializeProcess()
protected DistributedProcessHandler.ModelWithDependencies<BatchModel>	prepareInputBatch(SimpleBatchModel batch)

Methods inherited from class java.lang.Object

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

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:

initializeProcess in interface DistributedProcessHandler.ProcessInitializationContext

firstExecutionInputBatches

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

Specified by:

firstExecutionInputBatches in interface DistributedProcessHandler.ProcessInitializationContext

prepareInputBatch

protected DistributedProcessHandler.ModelWithDependencies<BatchModel> prepareInputBatch(SimpleBatchModel batch)