Package de.hybris.platform.impex.distributed.process

Class ImportProcessExecutionAnalysisContext

java.lang.Object

de.hybris.platform.impex.distributed.process.ImportProcessExecutionAnalysisContext

All Implemented Interfaces:

DistributedProcessHandler.ProcessExecutionAnalysisContext

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

Constructor Summary

Constructors

Constructor	Description
ImportProcessExecutionAnalysisContext(DistributedProcessModel process, ModelService modelService, FlexibleSearchService flexibleSearchService)

Method Summary

Modifier and Type	Method	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

ImportProcessExecutionAnalysisContext

public ImportProcessExecutionAnalysisContext(DistributedProcessModel process,
                                             ModelService modelService,
                                             FlexibleSearchService flexibleSearchService)

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