Class SimpleAbstractDistributedProcessCreationData
java.lang.Object
de.hybris.platform.processing.distributed.simple.data.SimpleAbstractDistributedProcessCreationData
- All Implemented Interfaces:
ProcessCreationData
- Direct Known Subclasses:
CollectionBasedCreationData,QueryBasedCreationData
public abstract class SimpleAbstractDistributedProcessCreationData
extends Object
implements ProcessCreationData
-
Field Summary
Fields -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedSimpleAbstractDistributedProcessCreationData(String handlerId, String processId, String scriptCode, String nodeGroup, Integer batchSize, Integer numOfRetries, Class<? extends SimpleDistributedProcessModel> processModelClass) -
Method Summary
Modifier and TypeMethodDescriptionintResponsible for returning spring bean id which will act as aDistributedProcessHandlerfor created process.Responsible for returning the node group, which may be assigned for the distributed process.intClass<? extends SimpleDistributedProcessModel>abstract Stream<? extends SimpleBatchCreationData>Responsible for returning stream for creating initial batches used by distributed process.
-
Field Details
-
DEFAULT_BATCH_SIZE
protected static final int DEFAULT_BATCH_SIZE- See Also:
-
DEFAULT_NUM_RETRIES
protected static final int DEFAULT_NUM_RETRIES- See Also:
-
processId
-
handlerId
-
scriptCode
-
nodeGroup
-
batchSize
protected final int batchSize -
numOfRetries
protected final int numOfRetries -
processModelClass
-
-
Constructor Details
-
SimpleAbstractDistributedProcessCreationData
-
-
Method Details
-
getProcessId
-
getNumOfRetries
public int getNumOfRetries() -
getBatchSize
public int getBatchSize() -
getScriptCode
-
getProcessModelClass
-
initialBatches
Description copied from interface:ProcessCreationDataResponsible for returning stream for creating initial batches used by distributed process.- Specified by:
initialBatchesin interfaceProcessCreationData- Returns:
- Stream of batch data
-
getHandlerBeanId
Description copied from interface:ProcessCreationDataResponsible for returning spring bean id which will act as aDistributedProcessHandlerfor created process.- Specified by:
getHandlerBeanIdin interfaceProcessCreationData- Returns:
- handler bean id
-
getNodeGroup
Description copied from interface:ProcessCreationDataResponsible for returning the node group, which may be assigned for the distributed process.- Specified by:
getNodeGroupin interfaceProcessCreationData- Returns:
- node group
-