de.hybris.y2ysync.task.distributed

Class Y2YSyncProcessAnalysisContext

java.lang.Object

de.hybris.y2ysync.task.distributed.Y2YSyncProcessAnalysisContext

All Implemented Interfaces:

DistributedProcessHandler.ProcessExecutionAnalysisContext

public class Y2YSyncProcessAnalysisContext
extends java.lang.Object
implements DistributedProcessHandler.ProcessExecutionAnalysisContext

Constructor Summary

Constructors

Constructor and Description
Y2YSyncProcessAnalysisContext(Y2YDistributedProcessModel process, FlexibleSearchService flexibleSearchService, ModelService modelService, DistributedProcessService distributedProcessService)

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>>	nextExecutionInputBatches()
DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel>	prepareProcessForNextExecution()
boolean	processFailed()
boolean	processSucceeded()

Methods inherited from class java.lang.Object

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

Constructor Detail

Y2YSyncProcessAnalysisContext

public Y2YSyncProcessAnalysisContext(Y2YDistributedProcessModel process,
                                     FlexibleSearchService flexibleSearchService,
                                     ModelService modelService,
                                     DistributedProcessService distributedProcessService)

Method Detail

processFailed

public boolean processFailed()

Specified by:

processFailed in interface DistributedProcessHandler.ProcessExecutionAnalysisContext

processSucceeded

public boolean processSucceeded()

Specified by:

processSucceeded in interface DistributedProcessHandler.ProcessExecutionAnalysisContext

nextExecutionInputBatches

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

Specified by:

nextExecutionInputBatches in interface DistributedProcessHandler.ProcessExecutionAnalysisContext

prepareProcessForNextExecution

public DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel> prepareProcessForNextExecution()

Specified by:

prepareProcessForNextExecution in interface DistributedProcessHandler.ProcessExecutionAnalysisContext