Class LookupFromIndexOperator
java.lang.Object
org.elasticsearch.compute.operator.AsyncOperator<LookupFromIndexOperator.OngoingJoin>
org.elasticsearch.xpack.esql.enrich.LookupFromIndexOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
public final class LookupFromIndexOperator
extends AsyncOperator<LookupFromIndexOperator.OngoingJoin>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final recordprotected static 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(String sessionId, DriverContext driverContext, CancellableTask parentTask, int maxOutstandingRequests, int inputChannel, LookupFromIndexService lookupService, DataType inputDataType, String lookupIndexPattern, String lookupIndex, String matchField, List<NamedExpression> loadFields, Source source) -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddoClose()booleanprotected voidperformAsync(Page inputPage, ActionListener<LookupFromIndexOperator.OngoingJoin> listener) protected voidprotected Operator.Statusstatus(long receivedPages, long completedPages, long totalTimeInMillis) toString()Methods inherited from class org.elasticsearch.compute.operator.AsyncOperator
addInput, close, fetchFromBuffer, finish, needsInput, releasePageOnAnyThread, status
-
Constructor Details
-
LookupFromIndexOperator
public LookupFromIndexOperator(String sessionId, DriverContext driverContext, CancellableTask parentTask, int maxOutstandingRequests, int inputChannel, LookupFromIndexService lookupService, DataType inputDataType, String lookupIndexPattern, String lookupIndex, String matchField, List<NamedExpression> loadFields, Source source)
-
-
Method Details
-
performAsync
protected void performAsync(Page inputPage, ActionListener<LookupFromIndexOperator.OngoingJoin> listener) - Specified by:
performAsyncin classAsyncOperator<LookupFromIndexOperator.OngoingJoin>
-
getOutput
-
releaseFetchedOnAnyThread
- Specified by:
releaseFetchedOnAnyThreadin classAsyncOperator<LookupFromIndexOperator.OngoingJoin>
-
toString
-
isFinished
public boolean isFinished()- Specified by:
isFinishedin interfaceOperator- Overrides:
isFinishedin classAsyncOperator<LookupFromIndexOperator.OngoingJoin>
-
isBlocked
- Specified by:
isBlockedin interfaceOperator- Overrides:
isBlockedin classAsyncOperator<LookupFromIndexOperator.OngoingJoin>
-
doClose
protected void doClose()- Specified by:
doClosein classAsyncOperator<LookupFromIndexOperator.OngoingJoin>
-
status
- Overrides:
statusin classAsyncOperator<LookupFromIndexOperator.OngoingJoin>
-