de.hybris.platform.impex.distributed.process

Class ImportProcessCreationData

java.lang.Object

de.hybris.platform.impex.distributed.process.ImportProcessCreationData

All Implemented Interfaces:

ProcessCreationData

public class ImportProcessCreationData
extends Object
implements ProcessCreationData

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ImportProcessCreationData.ImportProcessContext

Constructor Summary

Constructors

Constructor and Description
ImportProcessCreationData(String processCode, InputStream input, ImportDataDumpStrategy importDataDumpStrategy)
ImportProcessCreationData(String processCode, InputStream input, ImportDataDumpStrategy importDataDumpStrategy, ImportProcessCreationData.ImportProcessContext ctx)

Method Summary

Modifier and Type	Method and Description
void	connectToCronJob(ImpExImportCronJobModel model)
JobLogLevel	getEffectiveLogLevel()
String	getHandlerBeanId() Responsible for returning spring bean id which will act as a DistributedProcessHandler for created process.
ImportMetadata	getImportProcessMetadata()
String	getNodeGroup() Responsible for returning the node group, which may be assigned for the distributed process.
String	getProcessCode()
Stream<ImportBatchCreationData>	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

Constructor Detail

ImportProcessCreationData

public ImportProcessCreationData(String processCode,
                                 InputStream input,
                                 ImportDataDumpStrategy importDataDumpStrategy)

ImportProcessCreationData

public ImportProcessCreationData(String processCode,
                                 InputStream input,
                                 ImportDataDumpStrategy importDataDumpStrategy,
                                 ImportProcessCreationData.ImportProcessContext ctx)

Method Detail

initialBatches

public Stream<ImportBatchCreationData> 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

getProcessCode

public String getProcessCode()

getEffectiveLogLevel

public JobLogLevel getEffectiveLogLevel()

getImportProcessMetadata

public ImportMetadata getImportProcessMetadata()

connectToCronJob

public void connectToCronJob(ImpExImportCronJobModel model)