Package org.elasticsearch.xpack.esql.enrich

Class LookupFromIndexOperator

java.lang.Object

org.elasticsearch.compute.operator.AsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>

org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, Releasable

public final class LookupFromIndexOperator
extends AsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	LookupFromIndexOperator.Factory
static class	LookupFromIndexOperator.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
LookupFromIndexOperator(List<MatchConfig> matchFields, String sessionId, DriverContext driverContext, CancellableTask parentTask, int maxOutstandingRequests, LookupFromIndexService lookupService, String lookupIndexPattern, String lookupIndex, List<NamedExpression> loadFields, Source source, PhysicalPlan rightPreJoinPlan, Expression joinOnConditions)

Method Summary

Modifier and Type	Method	Description
protected void	doClose()
Page	getOutput()
IsBlockedResult	isBlocked()
boolean	isFinished()
protected void	performAsync(Page inputPage, ActionListener<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin> listener)
protected void	releaseFetchedOnAnyThread(org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin ongoingJoin)
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, 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

LookupFromIndexOperator

public LookupFromIndexOperator(List<MatchConfig> matchFields,
 String sessionId,
 DriverContext driverContext,
 CancellableTask parentTask,
 int maxOutstandingRequests,
 LookupFromIndexService lookupService,
 String lookupIndexPattern,
 String lookupIndex,
 List<NamedExpression> loadFields,
 Source source,
 PhysicalPlan rightPreJoinPlan,
 Expression joinOnConditions)

Method Details

performAsync

protected void performAsync(Page inputPage,
 ActionListener<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin> listener)

Specified by:

performAsync in class AsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>

getOutput

public Page getOutput()

releaseFetchedOnAnyThread

protected void releaseFetchedOnAnyThread(org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin ongoingJoin)

Specified by:

releaseFetchedOnAnyThread in class AsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>

toString

public String toString()

Overrides:

toString in class Object

isFinished

public boolean isFinished()

Specified by:

isFinished in interface Operator

Overrides:

isFinished in class AsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>

isBlocked

public IsBlockedResult isBlocked()

Specified by:

isBlocked in interface Operator

Overrides:

isBlocked in class AsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>

doClose

protected void doClose()

Specified by:

doClose in class AsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>

status

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

Overrides:

status in class AsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>