Class ImportProcessCreationData
java.lang.Object
de.hybris.platform.impex.distributed.process.ImportProcessCreationData
- All Implemented Interfaces:
ProcessCreationData
-
Nested Class Summary
Nested Classes -
Constructor Summary
ConstructorsConstructorDescriptionImportProcessCreationData(String processCode, InputStream input, ImportDataDumpStrategy importDataDumpStrategy) ImportProcessCreationData(String processCode, InputStream input, ImportDataDumpStrategy importDataDumpStrategy, ImportProcessCreationData.ImportProcessContext ctx) -
Method Summary
Modifier and TypeMethodDescriptionvoidResponsible for returning spring bean id which will act as aDistributedProcessHandlerfor created process.Responsible for returning the node group, which may be assigned for the distributed process.Responsible for returning stream for creating initial batches used by distributed process.
-
Constructor Details
-
ImportProcessCreationData
public ImportProcessCreationData(String processCode, InputStream input, ImportDataDumpStrategy importDataDumpStrategy) -
ImportProcessCreationData
public ImportProcessCreationData(String processCode, InputStream input, ImportDataDumpStrategy importDataDumpStrategy, ImportProcessCreationData.ImportProcessContext ctx)
-
-
Method Details
-
initialBatches
Description copied from interface:ProcessCreationDataResponsible for returning stream for creating initial batches used by distributed process.- Specified by:
initialBatchesin interfaceProcessCreationData- Returns:
- Stream of batch data
-
getHandlerBeanId
Description copied from interface:ProcessCreationDataResponsible for returning spring bean id which will act as aDistributedProcessHandlerfor created process.- Specified by:
getHandlerBeanIdin interfaceProcessCreationData- Returns:
- handler bean id
-
getNodeGroup
Description copied from interface:ProcessCreationDataResponsible for returning the node group, which may be assigned for the distributed process.- Specified by:
getNodeGroupin interfaceProcessCreationData- Returns:
- node group
-
getProcessCode
-
getEffectiveLogLevel
-
getImportProcessMetadata
-
connectToCronJob
-