Class SimpleDistributedProcessExecutionAnalysisContext
java.lang.Object
de.hybris.platform.processing.distributed.simple.context.SimpleDistributedProcessExecutionAnalysisContext
- All Implemented Interfaces:
DistributedProcessHandler.ProcessExecutionAnalysisContext
public class SimpleDistributedProcessExecutionAnalysisContext
extends Object
implements DistributedProcessHandler.ProcessExecutionAnalysisContext
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final DistributedProcessHandler.ProcessExecutionAnalysisContextprotected final DistributedProcessServiceprotected final FlexibleSearchServiceprotected final ModelServiceprotected final DistributedProcessModel -
Constructor Summary
ConstructorsConstructorDescriptionSimpleDistributedProcessExecutionAnalysisContext(FlexibleSearchService flexibleSearchService, ModelService modelService, DistributedProcessService distributedProcessService, DistributedProcessModel process) -
Method Summary
Modifier and TypeMethodDescriptionprotected longcountBatches(String countQuery) booleanbooleanprotected booleanprotected boolean
-
Field Details
-
flexibleSearchService
-
modelService
-
distributedProcessService
-
process
-
concreteCtx
-
-
Constructor Details
-
SimpleDistributedProcessExecutionAnalysisContext
public SimpleDistributedProcessExecutionAnalysisContext(FlexibleSearchService flexibleSearchService, ModelService modelService, DistributedProcessService distributedProcessService, DistributedProcessModel process)
-
-
Method Details
-
createConcreteCtx
-
thereAreUnfinishedBatches
protected boolean thereAreUnfinishedBatches() -
thereAreUnretryableBatches
protected boolean thereAreUnretryableBatches() -
countBatches
-
processFailed
public boolean processFailed()- Specified by:
processFailedin interfaceDistributedProcessHandler.ProcessExecutionAnalysisContext
-
processSucceeded
public boolean processSucceeded()- Specified by:
processSucceededin interfaceDistributedProcessHandler.ProcessExecutionAnalysisContext
-
nextExecutionInputBatches
public Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>> nextExecutionInputBatches()- Specified by:
nextExecutionInputBatchesin interfaceDistributedProcessHandler.ProcessExecutionAnalysisContext
-
prepareProcessForNextExecution
public DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel> prepareProcessForNextExecution()- Specified by:
prepareProcessForNextExecutionin interfaceDistributedProcessHandler.ProcessExecutionAnalysisContext
-