Class PojoMassIndexingBatchIndexingWorkspace<E,I>
- java.lang.Object
-
- org.hibernate.search.mapper.pojo.massindexing.impl.PojoMassIndexingFailureHandledRunnable
-
- org.hibernate.search.mapper.pojo.massindexing.impl.PojoMassIndexingBatchIndexingWorkspace<E,I>
-
- Type Parameters:
E- The type of indexed entities.I- The type of identifiers.
- All Implemented Interfaces:
Runnable
public class PojoMassIndexingBatchIndexingWorkspace<E,I> extends PojoMassIndexingFailureHandledRunnable
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 Description static StringTHREAD_NAME_PREFIX
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidcleanUpOnFailure()protected voidcleanUpOnInterruption()voidrunWithFailureHandler()-
Methods inherited from class org.hibernate.search.mapper.pojo.massindexing.impl.PojoMassIndexingFailureHandledRunnable
afterExecution, beforeExecution, createMassIndexingEnvironmentContext, getMassIndexingEnvironment, getNotifier, notifyError, notifyFailure, notifyInterrupted, notifySuccess, operationName, run, supportsThreadLifecycleHooks
-
-
-
-
Field Detail
-
THREAD_NAME_PREFIX
public static final String THREAD_NAME_PREFIX
- See Also:
- Constant Field Values
-
-
Method Detail
-
runWithFailureHandler
public void runWithFailureHandler() throws InterruptedException- Specified by:
runWithFailureHandlerin classPojoMassIndexingFailureHandledRunnable- Throws:
InterruptedException
-
cleanUpOnInterruption
protected void cleanUpOnInterruption()
- Specified by:
cleanUpOnInterruptionin classPojoMassIndexingFailureHandledRunnable
-
cleanUpOnFailure
protected void cleanUpOnFailure()
- Specified by:
cleanUpOnFailurein classPojoMassIndexingFailureHandledRunnable
-
-