org.hibernate.search.batchindexing.impl

Class BatchCoordinator

java.lang.Object

org.hibernate.search.batchindexing.impl.BatchCoordinator

All Implemented Interfaces:

Runnable

public class BatchCoordinator
extends Object

Makes sure that several different BatchIndexingWorkspace(s) can be started concurrently, sharing the same batch-backend and IndexWriters.

Author:

Sanne Grinovero

Field Summary

Fields

Modifier and Type	Field and Description
protected SearchFactoryImplementor	searchFactoryImplementor

Constructor Summary

Constructors

Constructor and Description
BatchCoordinator(Set<Class<?>> rootEntities, SearchFactoryImplementor searchFactoryImplementor, SessionFactoryImplementor sessionFactory, int typesToIndexInParallel, int documentBuilderThreads, CacheMode cacheMode, int objectLoadingBatchSize, long objectsLimit, boolean optimizeAtEnd, boolean purgeAtStart, boolean optimizeAfterPurge, MassIndexerProgressMonitor monitor, int idFetchSize)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	cleanUpOnError()
void	run()
void	runWithErrorHandler()

Methods inherited from class java.lang.Object

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

Field Detail

searchFactoryImplementor

protected final SearchFactoryImplementor searchFactoryImplementor

Constructor Detail

BatchCoordinator

public BatchCoordinator(Set<Class<?>> rootEntities,
                SearchFactoryImplementor searchFactoryImplementor,
                SessionFactoryImplementor sessionFactory,
                int typesToIndexInParallel,
                int documentBuilderThreads,
                CacheMode cacheMode,
                int objectLoadingBatchSize,
                long objectsLimit,
                boolean optimizeAtEnd,
                boolean purgeAtStart,
                boolean optimizeAfterPurge,
                MassIndexerProgressMonitor monitor,
                int idFetchSize)

Method Detail

runWithErrorHandler

public void runWithErrorHandler()

run

public final void run()

Specified by:

run in interface Runnable

cleanUpOnError

protected void cleanUpOnError()