Package de.hybris.platform.impex.jalo
Class MultiThreadedImporter
java.lang.Object
de.hybris.platform.impex.jalo.Importer
de.hybris.platform.impex.jalo.MultiThreadedImporter
- All Implemented Interfaces:
ImpExLogFilter.LocationProvider
- Since:
- 3.1-u7
-
Field Summary
Fields inherited from class de.hybris.platform.impex.jalo.Importer
LOG_INTERVAL -
Constructor Summary
ConstructorsConstructorDescriptionMultiThreadedImporter(MultiThreadedImpExImportReader importReader, int maxThreads) MultiThreadedImporter(CSVReader source) -
Method Summary
Modifier and TypeMethodDescriptionprotected ImpExImportReadercreateImportReader(CSVReader csvReader) Creates anImpExImportReaderinstance for processing given input.protected ImpExImportReaderCreates anImpExImportReaderinstance for next pass using dump handler for getting input stream and dump stream.Gets the current location within input stream as text representation.intprotected voidinit()Initializes the instance and switches to running state.voidsetLogFilter(ImpExLogFilter filter) Sets the logging filter to use while import.voidsetMaxThreads(int maxThreads) Methods inherited from class de.hybris.platform.impex.jalo.Importer
abortImport, activateLogFilter, assureStates, close, deactivateLogFilter, doImport, finishImport, getCurrentHeader, getCurrentLineNumber, getCurrentPass, getDumpedLineCountOverall, getDumpedLineCountPerHeader, getDumpedLineCountPerPass, getDumpHandler, getErrorHandler, getLastImportedItemLineNumber, getLogFilter, getMaxPass, getProcessedItemsCountOverall, getProcessedItemsCountPerHeader, getProcessedItemsCountPerPass, getReader, getResolvedItemsCountOverall, getResolvedItemsCountPerPass, getValueLineCountPerPass, hadError, hasUnresolvedLines, importAll, importNext, importNextInternal, isAborted, isFinished, isRunning, logProcess, prepareNextPass, setDumpHandler, setErrorHandler, setMaxPass, switchToState
-
Constructor Details
-
MultiThreadedImporter
-
MultiThreadedImporter
-
-
Method Details
-
createImportReader
Description copied from class:ImporterCreates anImpExImportReaderinstance for processing given input.- Overrides:
createImportReaderin classImporter- Parameters:
csvReader- reader covering input stream- Returns:
- new instance
-
createImportReaderForNextPass
Description copied from class:ImporterCreates anImpExImportReaderinstance for next pass using dump handler for getting input stream and dump stream.- Overrides:
createImportReaderForNextPassin classImporter- Returns:
- new reader instance for processing next pass
-
init
Description copied from class:ImporterInitializes the instance and switches to running state.- Overrides:
initin classImporter- Throws:
ImpExException- error while dump file creation
-
setLogFilter
Description copied from class:ImporterSets the logging filter to use while import. The default one extends each message with the current reader location except for info logs.- Overrides:
setLogFilterin classImporter- Parameters:
filter- new error handler instance
-
getMaxThreads
public int getMaxThreads() -
setMaxThreads
public void setMaxThreads(int maxThreads) -
getCurrentLocation
Description copied from class:ImporterGets the current location within input stream as text representation.- Specified by:
getCurrentLocationin interfaceImpExLogFilter.LocationProvider- Overrides:
getCurrentLocationin classImporter- Returns:
- current location text
- See Also:
-