Class EnrichLookupOperator
java.lang.Object
org.elasticsearch.compute.operator.AsyncOperator<Page>
org.elasticsearch.xpack.esql.enrich.EnrichLookupOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
-
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
ConstructorsConstructorDescriptionEnrichLookupOperator(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 TypeMethodDescriptionprotected voiddoClose()protected voidperformAsync(Page inputPage, ActionListener<Page> 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, isBlocked, isFinished, needsInput, releasePageOnAnyThread, status
-
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
- Specified by:
performAsyncin classAsyncOperator<Page>
-
getOutput
-
releaseFetchedOnAnyThread
- Specified by:
releaseFetchedOnAnyThreadin classAsyncOperator<Page>
-
toString
-
doClose
protected void doClose()- Specified by:
doClosein classAsyncOperator<Page>
-
status
- Overrides:
statusin classAsyncOperator<Page>
-