public class GenericMultiThreadedImporter extends Object implements ImporterRunner
Modifier and Type | Class and Description |
---|---|
static class |
GenericMultiThreadedImporter.NamedThreadFactory
Creates non-daemon threads at normal priority.
|
Modifier and Type | Field and Description |
---|---|
protected Integer |
batchSize |
protected static int |
DEFAULT_QUEUE_SIZE |
protected boolean |
enablePerfLogging |
protected ImporterDocumentModelFactory |
factory |
protected List<ImporterFilter> |
filters |
protected List<ImportingDocumentFilter> |
importingDocumentFilters |
protected SourceNode |
importSource |
protected static ThreadPoolExecutor |
importTP |
protected String |
importWritePath |
protected String |
jobName |
protected List<ImporterListener> |
listeners |
protected ImporterLogger |
log |
protected static Map<String,Long> |
nbCreatedDocsByThreads |
protected Integer |
nbThreads |
protected int |
queueSize |
protected String |
repositoryName |
protected GenericThreadedImportTask |
rootImportTask |
protected CoreSession |
session |
protected Boolean |
skipRootContainerCreation |
protected DocumentModel |
targetContainer |
protected ImporterThreadingPolicy |
threadPolicy |
protected Integer |
transactionTimeout |
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) |
protected static ThreadPoolExecutor importTP
protected static Map<String,Long> nbCreatedDocsByThreads
protected ImporterThreadingPolicy threadPolicy
protected ImporterDocumentModelFactory factory
protected SourceNode importSource
protected DocumentModel targetContainer
protected Integer transactionTimeout
protected ImporterLogger log
protected CoreSession session
protected String importWritePath
protected Boolean skipRootContainerCreation
protected boolean enablePerfLogging
protected List<ImporterFilter> filters
protected List<ImporterListener> listeners
protected List<ImportingDocumentFilter> importingDocumentFilters
protected GenericThreadedImportTask rootImportTask
protected static final int DEFAULT_QUEUE_SIZE
protected int queueSize
protected String repositoryName
public GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Boolean skipRootContainerCreation, Integer batchSize, Integer nbThreads, ImporterLogger log, int queueSize)
public GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Boolean skipRootContainerCreation, Integer batchSize, Integer nbThreads, ImporterLogger log)
public GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Integer batchSize, Integer nbThreads, ImporterLogger log)
public GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Boolean skipRootContainerCreation, Integer batchSize, Integer nbThreads, String jobName, ImporterLogger log)
public GenericMultiThreadedImporter(SourceNode sourceNode, String importWritePath, Integer batchSize, Integer nbThreads, String jobName, ImporterLogger log)
public GenericMultiThreadedImporter(ImporterRunnerConfiguration configuration)
public static ThreadPoolExecutor getExecutor()
public static void addCreatedDoc(String taskId, long nbDocs)
public static long getCreatedDocsCounter()
public void addFilter(ImporterFilter filter)
public void addListeners(ImporterListener... listeners)
public void addListeners(Collection<ImporterListener> listeners)
public void addImportingDocumentFilters(ImportingDocumentFilter... importingDocumentFilters)
public void addImportingDocumentFilters(Collection<ImportingDocumentFilter> importingDocumentFilters)
public void setRootImportTask(GenericThreadedImportTask rootImportTask)
protected GenericThreadedImportTask initRootTask(SourceNode importSource, DocumentModel targetContainer, boolean skipRootContainerCreation, ImporterLogger log, Integer batchSize, String jobName)
protected void doRun() throws IOException
IOException
protected static void sleep(int millis)
protected DocumentModel getTargetContainer()
protected DocumentModel createTargetContainer()
public ImporterThreadingPolicy getThreadPolicy()
public void setThreadPolicy(ImporterThreadingPolicy threadPolicy)
public ImporterDocumentModelFactory getFactory()
public void setFactory(ImporterDocumentModelFactory factory)
public void setTransactionTimeout(int transactionTimeout)
public void setEnablePerfLogging(boolean enablePerfLogging)
public void stopImportProcrocess()
stopImportProcrocess
in interface ImporterRunner
protected void notifyBeforeImport()
protected void notifyAfterImport()
public String getRepositoryName()
public void setRepositoryName(String repositoryName)
Copyright © 2016 Nuxeo SA. All rights reserved.