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
FieldsFields inherited from class org.hibernate.search.engine.backend.orchestration.spi.AbstractWorkOrchestrator
blockingRetryProducer -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected CompletableFuture<?>protected final ElasticsearchWorkExecutionContextprotected 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 Details
-
link
-
-
Constructor Details
-
ElasticsearchSimpleWorkOrchestrator
-
-
Method Details
-
submit
public <T> CompletableFuture<T> submit(NonBulkableWork<T> work, OperationSubmitter operationSubmitter) - Specified by:
submitin interfaceElasticsearchParallelWorkOrchestrator
-
doStart
- 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
- 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
-