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

Class AbstractNonBulkableWork<R>

java.lang.Object

org.hibernate.search.backend.elasticsearch.work.impl.AbstractNonBulkableWork<R>

All Implemented Interfaces:

ElasticsearchWork, NonBulkableWork<R>

Direct Known Subclasses:

BulkWork, ClearScrollWork, CloseIndexWork, CountWork, CreateIndexWork, DeleteByQueryWork, DropIndexWork, ExplainWork, FlushWork, ForceMergeWork, GetIndexMetadataWork, OpenIndexWork, PutIndexAliasesWork, PutIndexMappingWork, PutIndexSettingsWork, RefreshWork, ScrollWork, SearchWork, WaitForIndexStatusWork

public abstract class AbstractNonBulkableWork<R>
extends Object
implements NonBulkableWork<R>

Author:

Gunnar Morling

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractNonBulkableWork.AbstractBuilder<B>

Field Summary

Fields

Modifier and Type	Field	Description
protected ElasticsearchRequest	request
protected ElasticsearchRequestSuccessAssessor	resultAssessor

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractNonBulkableWork(AbstractNonBulkableWork.AbstractBuilder<?> builder)

Method Summary

Modifier and Type	Method	Description
protected CompletableFuture<?>	beforeExecute(ElasticsearchWorkExecutionContext executionContext, ElasticsearchRequest request)
CompletableFuture<R>	execute(ElasticsearchWorkExecutionContext executionContext)
protected abstract R	generateResult(ElasticsearchWorkExecutionContext context, ElasticsearchResponse response)
ElasticsearchRequest	request()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

request

protected final ElasticsearchRequest request

resultAssessor

protected final ElasticsearchRequestSuccessAssessor resultAssessor

Constructor Detail

AbstractNonBulkableWork

protected AbstractNonBulkableWork(AbstractNonBulkableWork.AbstractBuilder<?> builder)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

request

public ElasticsearchRequest request()

execute

public final CompletableFuture<R> execute(ElasticsearchWorkExecutionContext executionContext)

Specified by:

execute in interface NonBulkableWork<R>

beforeExecute

protected CompletableFuture<?> beforeExecute(ElasticsearchWorkExecutionContext executionContext,
                                             ElasticsearchRequest request)

generateResult

protected abstract R generateResult(ElasticsearchWorkExecutionContext context,
                                    ElasticsearchResponse response)