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

Class SimpleDistributedProcessExecutionAnalysisContext

java.lang.Object

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

All Implemented Interfaces:

DistributedProcessHandler.ProcessExecutionAnalysisContext

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

Field Summary

Fields

Modifier and Type	Field and Description
protected DistributedProcessHandler.ProcessExecutionAnalysisContext	concreteCtx
protected DistributedProcessService	distributedProcessService
protected FlexibleSearchService	flexibleSearchService
protected ModelService	modelService
protected DistributedProcessModel	process

Constructor Summary

Constructors

Constructor and Description
SimpleDistributedProcessExecutionAnalysisContext(FlexibleSearchService flexibleSearchService, ModelService modelService, DistributedProcessService distributedProcessService, DistributedProcessModel process)

Method Summary

Modifier and Type	Method and Description
protected long	countBatches(java.lang.String countQuery)
protected DistributedProcessHandler.ProcessExecutionAnalysisContext	createConcreteCtx()
java.util.stream.Stream<DistributedProcessHandler.ModelWithDependencies<BatchModel>>	nextExecutionInputBatches()
DistributedProcessHandler.ModelWithDependencies<DistributedProcessModel>	prepareProcessForNextExecution()
boolean	processFailed()
boolean	processSucceeded()
protected boolean	thereAreUnfinishedBatches()
protected boolean	thereAreUnretryableBatches()

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

distributedProcessService

protected final DistributedProcessService distributedProcessService

process

protected final DistributedProcessModel process

concreteCtx

protected final DistributedProcessHandler.ProcessExecutionAnalysisContext concreteCtx

Constructor Detail

SimpleDistributedProcessExecutionAnalysisContext

public SimpleDistributedProcessExecutionAnalysisContext(FlexibleSearchService flexibleSearchService,
                                                        ModelService modelService,
                                                        DistributedProcessService distributedProcessService,
                                                        DistributedProcessModel process)

Method Detail

createConcreteCtx

protected DistributedProcessHandler.ProcessExecutionAnalysisContext createConcreteCtx()

thereAreUnfinishedBatches

protected boolean thereAreUnfinishedBatches()

thereAreUnretryableBatches

protected boolean thereAreUnretryableBatches()

countBatches

protected long countBatches(java.lang.String countQuery)

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