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,org.elasticsearch.core.Releasable
public final class LookupFromIndexOperator
extends AsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final recordstatic classNested 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
ConstructorsConstructorDescriptionLookupFromIndexOperator(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 TypeMethodDescriptionprotected voiddoClose()booleanprotected voidperformAsync(Page inputPage, ActionListener<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin> listener) protected voidreleaseFetchedOnAnyThread(org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin ongoingJoin) protected Operator.Statusstatus(long receivedPages, long completedPages, long processNanos) toString()Methods inherited from class org.elasticsearch.compute.operator.AsyncOperator
addInput, canProduceMoreDataWithoutExtraInput, close, fetchFromBuffer, finish, needsInput, releasePageOnAnyThread, status
-
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:
performAsyncin classAsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>
-
getOutput
-
releaseFetchedOnAnyThread
protected void releaseFetchedOnAnyThread(org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin ongoingJoin) - Specified by:
releaseFetchedOnAnyThreadin classAsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>
-
toString
-
isFinished
public boolean isFinished()- Specified by:
isFinishedin interfaceOperator- Overrides:
isFinishedin classAsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>
-
isBlocked
- Specified by:
isBlockedin interfaceOperator- Overrides:
isBlockedin classAsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>
-
doClose
protected void doClose()- Specified by:
doClosein classAsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>
-
status
- Overrides:
statusin classAsyncOperator<org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator.OngoingJoin>
-