Package org.hibernate.search.mapper.pojo.massindexing.impl

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 final String	THREAD_NAME_PREFIX

Method Summary

Modifier and Type	Method	Description
protected void	cleanUpOnFailure()
protected void	cleanUpOnInterruption()
void	runWithFailureHandler()

Methods inherited from class org.hibernate.search.mapper.pojo.massindexing.impl.PojoMassIndexingFailureHandledRunnable

afterExecution, beforeExecution, createMassIndexingEnvironmentContext, getMassIndexingEnvironment, getNotifier, notifyError, notifyFailure, notifyInterrupted, notifySuccess, operationName, run, supportsThreadLifecycleHooks

Methods inherited from class java.lang.Object

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

Field Details

THREAD_NAME_PREFIX

public static final String THREAD_NAME_PREFIX

See Also:

• Constant Field Values

Method Details

runWithFailureHandler

public void runWithFailureHandler()
                           throws InterruptedException

Specified by:

runWithFailureHandler in class PojoMassIndexingFailureHandledRunnable

Throws:

InterruptedException

cleanUpOnInterruption

protected void cleanUpOnInterruption()

Specified by:

cleanUpOnInterruption in class PojoMassIndexingFailureHandledRunnable

cleanUpOnFailure

protected void cleanUpOnFailure()

Specified by:

cleanUpOnFailure in class PojoMassIndexingFailureHandledRunnable