de.hybris.platform.processing.distributed.simple

Class SimpleAbstractDistributedProcessHandler

java.lang.Object

de.hybris.platform.processing.distributed.simple.SimpleAbstractDistributedProcessHandler

All Implemented Interfaces:

DistributedProcessHandler

Direct Known Subclasses:

SimpleDistributedProcessHandler, SimpleScriptingDistributedProcessHandler

public abstract class SimpleAbstractDistributedProcessHandler
extends java.lang.Object
implements DistributedProcessHandler

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHandler

DistributedProcessHandler.ModelWithDependencies<T extends ItemModel>, DistributedProcessHandler.ProcessCreationContext, DistributedProcessHandler.ProcessExecutionAnalysisContext, DistributedProcessHandler.ProcessInitializationContext

Field Summary

Fields

Modifier and Type	Field and Description
protected DistributedProcessService	distributedProcessService
protected FlexibleSearchService	flexibleSearchService
protected static Logger	LOG
protected ModelService	modelService
static long	REMAINING_WORKLOAD
static long	WORK_DONE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimpleAbstractDistributedProcessHandler(ModelService modelService, FlexibleSearchService flexibleSearchService, DistributedProcessService distributedProcessService)

Method Summary

Modifier and Type	Method and Description
java.util.OptionalDouble	calculateProgress(DistributedProcessModel process)
SimpleProcessCreationContext	createProcessCreationContext(ProcessCreationData processData)
DistributedProcessHandler.ProcessExecutionAnalysisContext	createProcessExecutionAnalysisContext(DistributedProcessModel process)
DistributedProcessHandler.ProcessInitializationContext	createProcessInitializationContext(DistributedProcessModel process)
DistributedProcessHandler.ModelWithDependencies<BatchModel>	createResultBatch(BatchModel inputBatch)
void	onFinished(DistributedProcessModel process)
protected SimpleProcessCreationContext	prepareProcessCreationContext(SimpleAbstractDistributedProcessCreationData processData)
protected BatchModel	prepareResultBatch()
abstract void	processBatch(SimpleBatchModel inputBatch)

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHandler

getTypesWithDisabledUniquenessCheck, updateStatusInformation

Field Detail

LOG

protected static final Logger LOG

REMAINING_WORKLOAD

public static final long REMAINING_WORKLOAD

See Also:

Constant Field Values

WORK_DONE

public static final long WORK_DONE

See Also:

Constant Field Values

modelService

protected final ModelService modelService

flexibleSearchService

protected final FlexibleSearchService flexibleSearchService

distributedProcessService

protected final DistributedProcessService distributedProcessService

Constructor Detail

SimpleAbstractDistributedProcessHandler

protected SimpleAbstractDistributedProcessHandler(ModelService modelService,
                                                  FlexibleSearchService flexibleSearchService,
                                                  DistributedProcessService distributedProcessService)

Method Detail

createProcessCreationContext

public SimpleProcessCreationContext createProcessCreationContext(ProcessCreationData processData)

Specified by:

createProcessCreationContext in interface DistributedProcessHandler

prepareProcessCreationContext

protected SimpleProcessCreationContext prepareProcessCreationContext(SimpleAbstractDistributedProcessCreationData processData)

createProcessInitializationContext

public DistributedProcessHandler.ProcessInitializationContext createProcessInitializationContext(DistributedProcessModel process)

Specified by:

createProcessInitializationContext in interface DistributedProcessHandler

createResultBatch

public DistributedProcessHandler.ModelWithDependencies<BatchModel> createResultBatch(BatchModel inputBatch)

Specified by:

createResultBatch in interface DistributedProcessHandler

processBatch

public abstract void processBatch(SimpleBatchModel inputBatch)

prepareResultBatch

protected BatchModel prepareResultBatch()

createProcessExecutionAnalysisContext

public DistributedProcessHandler.ProcessExecutionAnalysisContext createProcessExecutionAnalysisContext(DistributedProcessModel process)

Specified by:

createProcessExecutionAnalysisContext in interface DistributedProcessHandler

onFinished

public void onFinished(DistributedProcessModel process)

Specified by:

onFinished in interface DistributedProcessHandler

calculateProgress

public java.util.OptionalDouble calculateProgress(DistributedProcessModel process)

Specified by:

calculateProgress in interface DistributedProcessHandler