de.hybris.y2ysync.task.distributed

Class Y2YSyncProcessInitializationContext

java.lang.Object

de.hybris.y2ysync.task.distributed.Y2YSyncProcessInitializationContext

All Implemented Interfaces:

DistributedProcessHandler.ProcessInitializationContext

public class Y2YSyncProcessInitializationContext
extends java.lang.Object
implements DistributedProcessHandler.ProcessInitializationContext

Constructor Summary

Constructors

Constructor and Description
Y2YSyncProcessInitializationContext(Y2YDistributedProcessModel process, FlexibleSearchService flexibleSearchService, ModelService modelService, MediaService mediaService, TypeService typeService, ChangeDetectionService changeDetectionService)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Y2YSyncProcessInitializationContext

public Y2YSyncProcessInitializationContext(Y2YDistributedProcessModel process,
                                           FlexibleSearchService flexibleSearchService,
                                           ModelService modelService,
                                           MediaService mediaService,
                                           TypeService typeService,
                                           ChangeDetectionService changeDetectionService)

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