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:

AnalyzeWork, 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 final ElasticsearchRequest	request
protected final 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)
final 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 Details

request

protected final ElasticsearchRequest request

resultAssessor

protected final ElasticsearchRequestSuccessAssessor resultAssessor

Constructor Details

AbstractNonBulkableWork

protected AbstractNonBulkableWork(AbstractNonBulkableWork.AbstractBuilder<?> builder)

Method Details

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)