Class CollectionBasedCreationData
java.lang.Object
de.hybris.platform.processing.distributed.simple.data.SimpleAbstractDistributedProcessCreationData
de.hybris.platform.processing.distributed.simple.data.CollectionBasedCreationData
- All Implemented Interfaces:
ProcessCreationData
Process creation data which is based on Collection. No further transformation is applied to the Collection elements.
Collection is divided into batches of the provided size. Keep in mind that elements must be serializable since they
are stored in a BLOB field of a Batch later on.
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsFields inherited from class de.hybris.platform.processing.distributed.simple.data.SimpleAbstractDistributedProcessCreationData
batchSize, DEFAULT_BATCH_SIZE, DEFAULT_NUM_RETRIES, handlerId, nodeGroup, numOfRetries, processId, processModelClass, scriptCode -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedCollectionBasedCreationData(String handlerId, String processId, String scriptCode, String nodeGroup, Integer batchSize, Integer numOfRetries, Collection<?> elements, Class<? extends SimpleDistributedProcessModel> processModelClass) -
Method Summary
Modifier and TypeMethodDescriptionbuilder()Stream<? extends SimpleBatchCreationData>Responsible for returning stream for creating initial batches used by distributed process.Methods inherited from class de.hybris.platform.processing.distributed.simple.data.SimpleAbstractDistributedProcessCreationData
getBatchSize, getHandlerBeanId, getNodeGroup, getNumOfRetries, getProcessId, getProcessModelClass, getScriptCode
-
Field Details
-
elements
-
-
Constructor Details
-
CollectionBasedCreationData
protected CollectionBasedCreationData(String handlerId, String processId, String scriptCode, String nodeGroup, Integer batchSize, Integer numOfRetries, Collection<?> elements, Class<? extends SimpleDistributedProcessModel> processModelClass)
-
-
Method Details
-
initialBatches
Description copied from interface:ProcessCreationDataResponsible for returning stream for creating initial batches used by distributed process.- Specified by:
initialBatchesin interfaceProcessCreationData- Specified by:
initialBatchesin classSimpleAbstractDistributedProcessCreationData- Returns:
- Stream of batch data
-
builder
-