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

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

Modifier and Type	Field and Description
protected int	batchSize
protected static int	DEFAULT_BATCH_SIZE
protected static int	DEFAULT_NUM_RETRIES
protected String	handlerId
protected String	nodeGroup
protected int	numOfRetries
protected String	processId
protected Class<? extends SimpleDistributedProcessModel>	processModelClass
protected String	scriptCode

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	getBatchSize()
String	getHandlerBeanId() Responsible for returning spring bean id which will act as a DistributedProcessHandler for created process.
String	getNodeGroup() Responsible for returning the node group, which may be assigned for the distributed process.
int	getNumOfRetries()
String	getProcessId()
Class<? extends SimpleDistributedProcessModel>	getProcessModelClass()
String	getScriptCode()
abstract Stream<? extends SimpleBatchCreationData>	initialBatches() Responsible for returning stream for creating initial batches used by distributed process.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BATCH_SIZE

protected static final int DEFAULT_BATCH_SIZE

See Also:

Constant Field Values

DEFAULT_NUM_RETRIES

protected static final int DEFAULT_NUM_RETRIES

See Also:

Constant Field Values

processId

protected final String processId

handlerId

protected final String handlerId

scriptCode

protected final String scriptCode

nodeGroup

protected final String nodeGroup

batchSize

protected final int batchSize

numOfRetries

protected final int numOfRetries

processModelClass

protected final Class<? extends SimpleDistributedProcessModel> processModelClass

Constructor Detail

SimpleAbstractDistributedProcessCreationData

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

Method Detail

getProcessId

public String getProcessId()

getNumOfRetries

public int getNumOfRetries()

getBatchSize

public int getBatchSize()

getScriptCode

public String getScriptCode()

getProcessModelClass

public Class<? extends SimpleDistributedProcessModel> getProcessModelClass()

initialBatches

public abstract 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

Returns:

Stream of batch data

getHandlerBeanId

public String getHandlerBeanId()

Description copied from interface: ProcessCreationData

Responsible for returning spring bean id which will act as a DistributedProcessHandler for created process.

Specified by:

getHandlerBeanId in interface ProcessCreationData

Returns:

handler bean id

getNodeGroup

public String getNodeGroup()

Description copied from interface: ProcessCreationData

Responsible for returning the node group, which may be assigned for the distributed process.

Specified by:

getNodeGroup in interface ProcessCreationData

Returns:

node group