Package 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 java.lang.Object
implements ProcessCreationData

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
int	getBatchSize()
java.lang.String	getHandlerBeanId()	Responsible for returning spring bean id which will act as a DistributedProcessHandler for created process.
java.lang.String	getNodeGroup()	Responsible for returning the node group, which may be assigned for the distributed process.
int	getNumOfRetries()
java.lang.String	getProcessId()
java.lang.Class<? extends SimpleDistributedProcessModel>	getProcessModelClass()
java.lang.String	getScriptCode()
abstract java.util.stream.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 java.lang.String processId

handlerId

protected final java.lang.String handlerId

scriptCode

protected final java.lang.String scriptCode

nodeGroup

protected final java.lang.String nodeGroup

batchSize

protected final int batchSize

numOfRetries

protected final int numOfRetries

processModelClass

protected final java.lang.Class<? extends SimpleDistributedProcessModel> processModelClass

Constructor Detail

SimpleAbstractDistributedProcessCreationData

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

Method Detail

getProcessId

public java.lang.String getProcessId()

getNumOfRetries

public int getNumOfRetries()

getBatchSize

public int getBatchSize()

getScriptCode

public java.lang.String getScriptCode()

getProcessModelClass

public java.lang.Class<? extends SimpleDistributedProcessModel> getProcessModelClass()

initialBatches

public abstract java.util.stream.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 java.lang.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 java.lang.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