de.hybris.platform.processing.distributed.simple.data

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

public class CollectionBasedCreationData
extends SimpleAbstractDistributedProcessCreationData

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

Modifier and Type	Class and Description
static class	CollectionBasedCreationData.Builder

Field Summary

Fields

Modifier and Type	Field and Description
protected Collection<?>	elements

Fields 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

Constructors

Modifier	Constructor and Description
protected	CollectionBasedCreationData(String handlerId, String processId, String scriptCode, String nodeGroup, Integer batchSize, Integer numOfRetries, Collection<?> elements, Class<? extends SimpleDistributedProcessModel> processModelClass)

Method Summary

Modifier and Type	Method and Description
static CollectionBasedCreationData.Builder	builder()
Stream<? extends SimpleBatchCreationData>	initialBatches() 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

Methods inherited from class java.lang.Object

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

Field Detail

elements

protected Collection<?> elements

Constructor Detail

CollectionBasedCreationData

protected CollectionBasedCreationData(String handlerId,
                                      String processId,
                                      String scriptCode,
                                      String nodeGroup,
                                      Integer batchSize,
                                      Integer numOfRetries,
                                      Collection<?> elements,
                                      Class<? extends SimpleDistributedProcessModel> processModelClass)

Method Detail

initialBatches

public Stream<? extends SimpleBatchCreationData> initialBatches()

Description copied from interface: ProcessCreationData

Responsible for returning stream for creating initial batches used by distributed process.

Specified by:

initialBatches in interface ProcessCreationData

Specified by:

initialBatches in class SimpleAbstractDistributedProcessCreationData

Returns:

Stream of batch data

builder

public static CollectionBasedCreationData.Builder builder()