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

Class PojoMassIndexingBatchCoordinator

java.lang.Object

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

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

All Implemented Interfaces:

Runnable

public class PojoMassIndexingBatchCoordinator
extends PojoMassIndexingFailureHandledRunnable

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

Author:

Sanne Grinovero

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PojoMassIndexingBatchCoordinator.SessionContext

Constructor Summary

Constructors

Constructor

Description

PojoMassIndexingBatchCoordinator(PojoMassIndexingMappingContext mappingContext, PojoMassIndexingNotifier notifier, List<PojoMassIndexingIndexedTypeGroup<?>> typeGroupsToIndex, PojoScopeSchemaManager scopeSchemaManager, Set<String> tenantIds, PojoScopeDelegate<?,?,?> pojoScopeDelegate, MassIndexingEnvironment environment, int typesToIndexInParallel, int documentBuilderThreads, boolean mergeSegmentsOnFinish, boolean dropAndCreateSchemaOnStart, boolean purgeAtStart, boolean mergeSegmentsAfterPurge)

Method Summary

Modifier and Type	Method	Description
protected void	cleanUpOnFailure()
protected void	cleanUpOnInterruption()
protected void	notifyFailure(RuntimeException exception)
protected void	notifyInterrupted(InterruptedException exception)
protected void	notifySuccess()
void	runWithFailureHandler()

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

afterExecution, beforeExecution, createMassIndexingEnvironmentContext, getMassIndexingEnvironment, getNotifier, notifyError, operationName, run, supportsThreadLifecycleHooks

Methods inherited from class java.lang.Object

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

Constructor Detail

PojoMassIndexingBatchCoordinator

public PojoMassIndexingBatchCoordinator(PojoMassIndexingMappingContext mappingContext,
                                        PojoMassIndexingNotifier notifier,
                                        List<PojoMassIndexingIndexedTypeGroup<?>> typeGroupsToIndex,
                                        PojoScopeSchemaManager scopeSchemaManager,
                                        Set<String> tenantIds,
                                        PojoScopeDelegate<?,?,?> pojoScopeDelegate,
                                        MassIndexingEnvironment environment,
                                        int typesToIndexInParallel,
                                        int documentBuilderThreads,
                                        boolean mergeSegmentsOnFinish,
                                        boolean dropAndCreateSchemaOnStart,
                                        boolean purgeAtStart,
                                        boolean mergeSegmentsAfterPurge)

Method Detail

runWithFailureHandler

public void runWithFailureHandler()
                           throws InterruptedException

Specified by:

runWithFailureHandler in class PojoMassIndexingFailureHandledRunnable

Throws:

InterruptedException

cleanUpOnInterruption

protected void cleanUpOnInterruption()
                              throws InterruptedException

Specified by:

cleanUpOnInterruption in class PojoMassIndexingFailureHandledRunnable

Throws:

InterruptedException

cleanUpOnFailure

protected void cleanUpOnFailure()

Specified by:

cleanUpOnFailure in class PojoMassIndexingFailureHandledRunnable

notifySuccess

protected void notifySuccess()

Overrides:

notifySuccess in class PojoMassIndexingFailureHandledRunnable

notifyInterrupted

protected void notifyInterrupted(InterruptedException exception)

Overrides:

notifyInterrupted in class PojoMassIndexingFailureHandledRunnable

notifyFailure

protected void notifyFailure(RuntimeException exception)

Overrides:

notifyFailure in class PojoMassIndexingFailureHandledRunnable