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 ElasticsearchLinklink-
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected CompletableFuture<?>completion()protected ElasticsearchWorkExecutionContextcreateWorkExecutionContext()protected voiddoStart(ConfigurationPropertySource propertySource)protected voiddoStop()protected voiddoSubmit(org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?> work, OperationSubmitter ignore)<T> CompletableFuture<T>submit(NonBulkableWork<T> work, OperationSubmitter operationSubmitter)
-
-
-
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:
submitin interfaceElasticsearchParallelWorkOrchestrator
-
doStart
protected void doStart(ConfigurationPropertySource propertySource)
- Specified by:
doStartin classAbstractWorkOrchestrator<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:
doSubmitin classAbstractWorkOrchestrator<org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?>>
-
completion
protected CompletableFuture<?> completion()
- Specified by:
completionin classAbstractWorkOrchestrator<org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?>>
-
doStop
protected void doStop()
- Specified by:
doStopin classAbstractWorkOrchestrator<org.hibernate.search.backend.elasticsearch.orchestration.impl.ElasticsearchSimpleWorkOrchestrator.WorkExecution<?>>
-
createWorkExecutionContext
protected final ElasticsearchWorkExecutionContext createWorkExecutionContext()
-
-