org.hibernate.search.batchindexing.impl

Class BatchIndexingWorkspace

java.lang.Object

org.hibernate.search.batchindexing.impl.BatchIndexingWorkspace

All Implemented Interfaces:

Runnable

public class BatchIndexingWorkspace
extends Object

This runnable will prepare a pipeline for batch indexing of entities, managing the lifecycle of several ThreadPools.

Author:

Sanne Grinovero

Field Summary

Fields

Modifier and Type	Field and Description
protected SearchFactoryImplementor	searchFactoryImplementor

Constructor Summary

Constructors

Constructor and Description
BatchIndexingWorkspace(SearchFactoryImplementor searchFactoryImplementor, SessionFactoryImplementor sessionFactory, Class<?> entityType, int objectLoadingThreads, CacheMode cacheMode, int objectLoadingBatchSize, CountDownLatch endAllSignal, MassIndexerProgressMonitor monitor, BatchBackend backend, long objectsLimit, 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

BatchIndexingWorkspace

public BatchIndexingWorkspace(SearchFactoryImplementor searchFactoryImplementor,
                      SessionFactoryImplementor sessionFactory,
                      Class<?> entityType,
                      int objectLoadingThreads,
                      CacheMode cacheMode,
                      int objectLoadingBatchSize,
                      CountDownLatch endAllSignal,
                      MassIndexerProgressMonitor monitor,
                      BatchBackend backend,
                      long objectsLimit,
                      int idFetchSize)

Method Detail

runWithErrorHandler

public void runWithErrorHandler()

run

public final void run()

Specified by:

run in interface Runnable

cleanUpOnError

protected void cleanUpOnError()