org.alfresco.repo.bulkimport.impl
Class StripingBulkFilesystemImporter

java.lang.Object
  org.alfresco.repo.bulkimport.impl.AbstractBulkFilesystemImporter
      org.alfresco.repo.bulkimport.impl.MultiThreadedBulkFilesystemImporter
          org.alfresco.repo.bulkimport.impl.StripingBulkFilesystemImporter

All Implemented Interfaces:

BulkFilesystemImporter, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware

public class StripingBulkFilesystemImporter
extends MultiThreadedBulkFilesystemImporter

A multi threaded bulk importer that imports by striping across filesystem levels.

Since:

4.0

Field Summary

Fields inherited from class org.alfresco.repo.bulkimport.impl.MultiThreadedBulkFilesystemImporter

defaultBatchSize, defaultLoggingInterval, defaultNumThreads, logger

Fields inherited from class org.alfresco.repo.bulkimport.impl.AbstractBulkFilesystemImporter

applicationContext, behaviourFilter, directoryAnalyser, fileFolderService, importStatus, jobLockService, permissionService, ruleService, transactionHelper, transactionService

Constructor Summary

StripingBulkFilesystemImporter()

Method Summary

protected void

bulkImportImpl(BulkImportParameters bulkImportParameters, NodeImporter nodeImporter, java.lang.String lockToken) Method that does the work of importing a filesystem using the BatchProcessor.

Methods inherited from class org.alfresco.repo.bulkimport.impl.MultiThreadedBulkFilesystemImporter

getBatchProcessor, getBatchSize, getDefaultBatchSize, getDefaultNumThreads, getLoggingInterval, getNumThreads, getWorker, setDefaultBatchSize, setDefaultNumThreads

Methods inherited from class org.alfresco.repo.bulkimport.impl.AbstractBulkFilesystemImporter

afterPropertiesSet, asyncBulkImport, bulkImport, getFileName, getLock, getLockToken, getRepositoryPath, getStatus, mapToString, refreshLock, releaseLock, setApplicationContext, setBehaviourFilter, setDirectoryAnalyser, setFileFolderService, setImportStatus, setJobLockService, setPermissionService, setRuleService, setTransactionService, validateNodeRefIsWritableSpace, validateSourceIsReadableDirectory

Methods inherited from class java.lang.Object

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

Constructor Detail

StripingBulkFilesystemImporter

public StripingBulkFilesystemImporter()

Method Detail

bulkImportImpl

protected void bulkImportImpl(BulkImportParameters bulkImportParameters,
                              NodeImporter nodeImporter,
                              java.lang.String lockToken)

Method that does the work of importing a filesystem using the BatchProcessor.

Overrides:

bulkImportImpl in class MultiThreadedBulkFilesystemImporter

Parameters:

bulkImportParameters - The bulk import parameters to apply to this bulk import.

nodeImporter - The node importer implementation that will import each node.

lockToken - The lock token to use during the bulk import.