de.hybris.y2ysync.task.distributed

Class Y2YSyncProcessCreationData

java.lang.Object

de.hybris.y2ysync.task.distributed.Y2YSyncProcessCreationData

All Implemented Interfaces:

ProcessCreationData

public class Y2YSyncProcessCreationData
extends java.lang.Object
implements ProcessCreationData

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Y2YSyncProcessCreationData.Builder

Method Summary

Modifier and Type	Method and Description
static Y2YSyncProcessCreationData.Builder	builder()
int	getBatchSize()
Y2YStreamConfigurationContainerModel	getContainer()
java.lang.String	getDataHubUrl()
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.
java.lang.String	getProcessId()
Y2YSyncType	getSyncType()
java.util.stream.Stream<? extends StreamConfiguration>	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

Method Detail

getProcessId

public java.lang.String getProcessId()

initialBatches

public java.util.stream.Stream<? extends StreamConfiguration> 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

getContainer

public Y2YStreamConfigurationContainerModel getContainer()

getSyncType

public Y2YSyncType getSyncType()

getDataHubUrl

public java.lang.String getDataHubUrl()

getBatchSize

public int getBatchSize()

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

builder

public static Y2YSyncProcessCreationData.Builder builder()