org.nuxeo.ecm.platform.importer.base

Class GenericMultiThreadedImporter

java.lang.Object

org.nuxeo.ecm.platform.importer.base.GenericMultiThreadedImporter

All Implemented Interfaces:

Runnable, ImporterRunner

public class GenericMultiThreadedImporter
extends Object
implements ImporterRunner

Generic importer

Author:

Thierry Delprat

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GenericMultiThreadedImporter.NamedThreadFactory Creates non-daemon threads at normal priority.

Constructor Summary

Constructors

Constructor and Description
GenericMultiThreadedImporter(ImporterRunnerConfiguration configuration)
GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Boolean skipRootContainerCreation, Integer batchSize, Integer nbThreads, ImporterLogger log)
GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Boolean skipRootContainerCreation, Integer batchSize, Integer nbThreads, ImporterLogger log, int queueSize)
GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Boolean skipRootContainerCreation, Integer batchSize, Integer nbThreads, String jobName, ImporterLogger log)
GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Integer batchSize, Integer nbThreads, ImporterLogger log)
GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Integer batchSize, Integer nbThreads, String jobName, ImporterLogger log)

Method Summary

Methods

Modifier and Type	Method and Description
static void	addCreatedDoc(String taskId, long nbDocs)
void	addFilter(ImporterFilter filter)
void	addImportingDocumentFilters(Collection<ImportingDocumentFilter> importingDocumentFilters)
void	addImportingDocumentFilters(ImportingDocumentFilter... importingDocumentFilters)
void	addListeners(Collection<ImporterListener> listeners)
void	addListeners(ImporterListener... listeners)
static long	getCreatedDocsCounter()
static ThreadPoolExecutor	getExecutor()
ImporterDocumentModelFactory	getFactory()
ImporterThreadingPolicy	getThreadPolicy()
void	run()
void	setEnablePerfLogging(boolean enablePerfLogging)
void	setFactory(ImporterDocumentModelFactory factory)
void	setRootImportTask(GenericThreadedImportTask rootImportTask)
void	setThreadPolicy(ImporterThreadingPolicy threadPolicy)
void	setTransactionTimeout(int transactionTimeout)
void	stopImportProcrocess()

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericMultiThreadedImporter

public GenericMultiThreadedImporter(SourceNode sourceNode,
                            String importWritePath,
                            Boolean skipRootContainerCreation,
                            Integer batchSize,
                            Integer nbThreads,
                            ImporterLogger log,
                            int queueSize)
                             throws Exception

Throws:

Exception

GenericMultiThreadedImporter

public GenericMultiThreadedImporter(SourceNode sourceNode,
                            String importWritePath,
                            Boolean skipRootContainerCreation,
                            Integer batchSize,
                            Integer nbThreads,
                            ImporterLogger log)
                             throws Exception

Throws:

Exception

GenericMultiThreadedImporter

public GenericMultiThreadedImporter(SourceNode sourceNode,
                            String importWritePath,
                            Integer batchSize,
                            Integer nbThreads,
                            ImporterLogger log)
                             throws Exception

Throws:

Exception

GenericMultiThreadedImporter

public GenericMultiThreadedImporter(SourceNode sourceNode,
                            String importWritePath,
                            Boolean skipRootContainerCreation,
                            Integer batchSize,
                            Integer nbThreads,
                            String jobName,
                            ImporterLogger log)
                             throws Exception

Throws:

Exception

GenericMultiThreadedImporter

public GenericMultiThreadedImporter(SourceNode sourceNode,
                            String importWritePath,
                            Integer batchSize,
                            Integer nbThreads,
                            String jobName,
                            ImporterLogger log)
                             throws Exception

Throws:

Exception

GenericMultiThreadedImporter

public GenericMultiThreadedImporter(ImporterRunnerConfiguration configuration)
                             throws Exception

Throws:

Exception

Method Detail

getExecutor

public static ThreadPoolExecutor getExecutor()

addCreatedDoc

public static void addCreatedDoc(String taskId,
                 long nbDocs)

getCreatedDocsCounter

public static long getCreatedDocsCounter()

addFilter

public void addFilter(ImporterFilter filter)

addListeners

public void addListeners(ImporterListener... listeners)

addListeners

public void addListeners(Collection<ImporterListener> listeners)

addImportingDocumentFilters

public void addImportingDocumentFilters(ImportingDocumentFilter... importingDocumentFilters)

addImportingDocumentFilters

public void addImportingDocumentFilters(Collection<ImportingDocumentFilter> importingDocumentFilters)

run

public void run()

Specified by:

run in interface Runnable

setRootImportTask

public void setRootImportTask(GenericThreadedImportTask rootImportTask)

getThreadPolicy

public ImporterThreadingPolicy getThreadPolicy()

setThreadPolicy

public void setThreadPolicy(ImporterThreadingPolicy threadPolicy)

getFactory

public ImporterDocumentModelFactory getFactory()

setFactory

public void setFactory(ImporterDocumentModelFactory factory)

setTransactionTimeout

public void setTransactionTimeout(int transactionTimeout)

Since:

5.9.4

setEnablePerfLogging

public void setEnablePerfLogging(boolean enablePerfLogging)

stopImportProcrocess

public void stopImportProcrocess()

Specified by:

stopImportProcrocess in interface ImporterRunner