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

public class MultiThreadedImporter
extends Importer

Since:

3.1-u7

Field Summary

Fields inherited from class de.hybris.platform.impex.jalo.Importer

LOG_INTERVAL

Constructor Summary

Constructors

Constructor and Description
MultiThreadedImporter(CSVReader source)
MultiThreadedImporter(MultiThreadedImpExImportReader importReader, int maxThreads)

Method Summary

Modifier and Type	Method and Description
protected ImpExImportReader	createImportReader(CSVReader csvReader) Creates an ImpExImportReader instance for processing given input.
protected ImpExImportReader	createImportReaderForNextPass() Creates an ImpExImportReader instance for next pass using dump handler for getting input stream and dump stream.
java.lang.String	getCurrentLocation() Gets the current location within input stream as text representation.
int	getMaxThreads()
protected void	init() Initializes the instance and switches to running state.
void	setLogFilter(ImpExLogFilter filter) Sets the logging filter to use while import.
void	setMaxThreads(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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultiThreadedImporter

public MultiThreadedImporter(CSVReader source)

MultiThreadedImporter

public MultiThreadedImporter(MultiThreadedImpExImportReader importReader,
                             int maxThreads)

Method Detail

createImportReader

protected ImpExImportReader createImportReader(CSVReader csvReader)

Description copied from class: Importer

Creates an ImpExImportReader instance for processing given input.

Overrides:

createImportReader in class Importer

Parameters:

csvReader - reader covering input stream

Returns:

new instance

createImportReaderForNextPass

protected ImpExImportReader createImportReaderForNextPass()

Description copied from class: Importer

Creates an ImpExImportReader instance for next pass using dump handler for getting input stream and dump stream.

Overrides:

createImportReaderForNextPass in class Importer

Returns:

new reader instance for processing next pass

init

protected void init()
             throws ImpExException

Description copied from class: Importer

Initializes the instance and switches to running state.

Overrides:

init in class Importer

Throws:

ImpExException - error while dump file creation

setLogFilter

public void setLogFilter(ImpExLogFilter filter)

Description copied from class: Importer

Sets the logging filter to use while import. The default one extends each message with the current reader location except for info logs.

Overrides:

setLogFilter in class Importer

Parameters:

filter - new error handler instance

getMaxThreads

public int getMaxThreads()

setMaxThreads

public void setMaxThreads(int maxThreads)

getCurrentLocation

public java.lang.String getCurrentLocation()

Description copied from class: Importer

Gets the current location within input stream as text representation.

Specified by:

getCurrentLocation in interface ImpExLogFilter.LocationProvider

Overrides:

getCurrentLocation in class Importer

Returns:

current location text

See Also:

ImpExReader.getCurrentLocation()