Package org.elasticsearch.xpack.esql.enrich

Class EnrichLookupOperator

java.lang.Object

org.elasticsearch.compute.operator.AsyncOperator<Page>

org.elasticsearch.xpack.esql.enrich.EnrichLookupOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, Releasable

public final class EnrichLookupOperator
extends AsyncOperator<Page>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	EnrichLookupOperator.Factory
static class	EnrichLookupOperator.Status

Nested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator

Operator.OperatorFactory

Field Summary

Fields inherited from interface org.elasticsearch.compute.operator.Operator

MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
EnrichLookupOperator(String sessionId, DriverContext driverContext, CancellableTask parentTask, int maxOutstandingRequests, int inputChannel, EnrichLookupService enrichLookupService, DataType inputDataType, String enrichIndex, String matchType, String matchField, List<NamedExpression> enrichFields, Source source)

Method Summary

Modifier and Type	Method	Description
protected void	doClose()
Page	getOutput()
protected void	performAsync(Page inputPage, ActionListener<Page> listener)
protected void	releaseFetchedOnAnyThread(Page page)
protected Operator.Status	status(long receivedPages, long completedPages, long processNanos)
String	toString()

Methods inherited from class org.elasticsearch.compute.operator.AsyncOperator

addInput, canProduceMoreDataWithoutExtraInput, close, fetchFromBuffer, finish, isBlocked, isFinished, needsInput, releasePageOnAnyThread, status

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.compute.operator.Operator

tryPromote

Constructor Details

EnrichLookupOperator

public EnrichLookupOperator(String sessionId,
 DriverContext driverContext,
 CancellableTask parentTask,
 int maxOutstandingRequests,
 int inputChannel,
 EnrichLookupService enrichLookupService,
 DataType inputDataType,
 String enrichIndex,
 String matchType,
 String matchField,
 List<NamedExpression> enrichFields,
 Source source)

Method Details

performAsync

protected void performAsync(Page inputPage,
 ActionListener<Page> listener)

Specified by:

performAsync in class AsyncOperator<Page>

getOutput

public Page getOutput()

releaseFetchedOnAnyThread

protected void releaseFetchedOnAnyThread(Page page)

Specified by:

releaseFetchedOnAnyThread in class AsyncOperator<Page>

toString

public String toString()

Overrides:

toString in class Object

doClose

protected void doClose()

Specified by:

doClose in class AsyncOperator<Page>

status

protected Operator.Status status(long receivedPages,
 long completedPages,
 long processNanos)

Overrides:

status in class AsyncOperator<Page>