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

Class ElasticsearchSimpleWorkOrchestrator

java.lang.Object

org.hibernate.search.engine.backend.orchestration.spi.AbstractWorkOrchestrator<W>

org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator

All Implemented Interfaces:

ElasticsearchParallelWorkOrchestrator

public class ElasticsearchSimpleWorkOrchestrator
extends AbstractWorkOrchestrator<W>
implements ElasticsearchParallelWorkOrchestrator

Field Summary

Fields

Modifier and Type	Field	Description
protected ElasticsearchLink	link

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

blockingRetryProducer

Constructor Summary

Constructors

Constructor	Description
ElasticsearchSimpleWorkOrchestrator(String name, ElasticsearchLink link)

Method Summary

Modifier and Type	Method	Description
protected CompletableFuture<?>	completion()
protected ElasticsearchWorkExecutionContext	createWorkExecutionContext()
protected void	doStart(ConfigurationPropertySource propertySource)
protected void	doStop()
protected void	doSubmit(org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?> work, OperationSubmitter ignore)
<T> CompletableFuture<T>	submit(NonBulkableWork<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

Field Detail

link

protected final ElasticsearchLink link

Constructor Detail

ElasticsearchSimpleWorkOrchestrator

public ElasticsearchSimpleWorkOrchestrator(String name,
                                           ElasticsearchLink link)

Method Detail

submit

public <T> CompletableFuture<T> submit(NonBulkableWork<T> work,
                                       OperationSubmitter operationSubmitter)

Specified by:

submit in interface ElasticsearchParallelWorkOrchestrator

doStart

protected void doStart(ConfigurationPropertySource propertySource)

Specified by:

doStart in class AbstractWorkOrchestrator<org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?>>

doSubmit

protected void doSubmit(org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?> work,
                        OperationSubmitter ignore)

Specified by:

doSubmit in class AbstractWorkOrchestrator<org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?>>

completion

protected CompletableFuture<?> completion()

Specified by:

completion in class AbstractWorkOrchestrator<org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?>>

doStop

protected void doStop()

Specified by:

doStop in class AbstractWorkOrchestrator<org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?>>

createWorkExecutionContext

protected final ElasticsearchWorkExecutionContext createWorkExecutionContext()