Package org.hibernate.search.backend.lucene.orchestration.impl

Class LuceneParallelWorkOrchestratorImpl

java.lang.Object

org.hibernate.search.engine.backend.orchestration.spi.AbstractWorkOrchestrator<org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl.WorkExecution<?>>

org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl

All Implemented Interfaces:

LuceneParallelWorkOrchestrator

public class LuceneParallelWorkOrchestratorImpl
extends AbstractWorkOrchestrator<org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl.WorkExecution<?>>
implements LuceneParallelWorkOrchestrator

Field Summary

Fields inherited from class org.hibernate.search.engine.backend.orchestration.spi.AbstractWorkOrchestrator

blockingRetryProducer

Constructor Summary

Constructors

Constructor	Description
LuceneParallelWorkOrchestratorImpl(String name, EventContext eventContext, IndexAccessor indexAccessor, BackendThreads threads)

Method Summary

Modifier and Type	Method	Description
protected CompletableFuture<?>	completion()
protected void	doStart(ConfigurationPropertySource propertySource)
protected void	doStop()
protected void	doSubmit(org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl.WorkExecution<?> workExecution, OperationSubmitter operationSubmitter)
void	forceCommitInCurrentThread()	Force a commit immediately.
<T> void	submit(CompletableFuture<T> future, IndexManagementWork<T> work, OperationSubmitter operationSubmitter)

Methods inherited from class org.hibernate.search.engine.backend.orchestration.spi.AbstractWorkOrchestrator

name, preStop, start, stop, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestrator

submit

Constructor Detail

LuceneParallelWorkOrchestratorImpl

public LuceneParallelWorkOrchestratorImpl(String name,
                                          EventContext eventContext,
                                          IndexAccessor indexAccessor,
                                          BackendThreads threads)

Method Detail

submit

public <T> void submit(CompletableFuture<T> future,
                       IndexManagementWork<T> work,
                       OperationSubmitter operationSubmitter)

Specified by:

submit in interface LuceneParallelWorkOrchestrator

forceCommitInCurrentThread

public void forceCommitInCurrentThread()

Description copied from interface: LuceneParallelWorkOrchestrator

Force a commit immediately.

The commit will be executed in the current thread.

Specified by:

forceCommitInCurrentThread in interface LuceneParallelWorkOrchestrator

doStart

protected void doStart(ConfigurationPropertySource propertySource)

Specified by:

doStart in class AbstractWorkOrchestrator<org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl.WorkExecution<?>>

doSubmit

protected void doSubmit(org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl.WorkExecution<?> workExecution,
                        OperationSubmitter operationSubmitter)
                 throws InterruptedException

Specified by:

doSubmit in class AbstractWorkOrchestrator<org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl.WorkExecution<?>>

Throws:

InterruptedException

completion

protected CompletableFuture<?> completion()

Specified by:

completion in class AbstractWorkOrchestrator<org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl.WorkExecution<?>>

doStop

protected void doStop()

Specified by:

doStop in class AbstractWorkOrchestrator<org.hibernate.search.backend.lucene.orchestration.impl.LuceneParallelWorkOrchestratorImpl.WorkExecution<?>>