Class LookupFromIndexService
java.lang.Object
org.elasticsearch.xpack.esql.enrich.AbstractLookupService<LookupFromIndexService.Request,LookupFromIndexService.TransportRequest>
org.elasticsearch.xpack.esql.enrich.LookupFromIndexService
public class LookupFromIndexService
extends AbstractLookupService<LookupFromIndexService.Request,LookupFromIndexService.TransportRequest>
LookupFromIndexService performs lookup against a Lookup index for
a given input page. See AbstractLookupService for how it works
where it refers to this process as a LEFT JOIN. Which is mostly is.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected static classstatic classprotected static classNested classes/interfaces inherited from class org.elasticsearch.xpack.esql.enrich.AbstractLookupService
AbstractLookupService.LookupShardContext, AbstractLookupService.LookupShardContextFactory -
Field Summary
FieldsFields inherited from class org.elasticsearch.xpack.esql.enrich.AbstractLookupService
clusterService, executor, transportService -
Constructor Summary
ConstructorsConstructorDescriptionLookupFromIndexService(ClusterService clusterService, AbstractLookupService.LookupShardContextFactory lookupShardContextFactory, TransportService transportService, BigArrays bigArrays, BlockFactory blockFactory) -
Method Summary
Modifier and TypeMethodDescriptionprotected LookupFromIndexService.LookupResponsecreateLookupResponse(List<Page> pages, BlockFactory blockFactory) Build the response.protected QueryListqueryList(LookupFromIndexService.TransportRequest request, SearchExecutionContext context, Block inputBlock, DataType inputDataType) Build a list of queries to perform inside the actual lookup.protected org.elasticsearch.xpack.esql.enrich.AbstractLookupService.LookupResponsereadLookupResponse(StreamInput in, BlockFactory blockFactory) Read the response from aStreamInput.protected LookupFromIndexService.TransportRequesttransportRequest(LookupFromIndexService.Request request, ShardId shardId) Convert a request as sent toAbstractLookupService.lookupAsync(R, org.elasticsearch.tasks.CancellableTask, org.elasticsearch.action.ActionListener<java.util.List<org.elasticsearch.compute.data.Page>>)into a transport request after preflight checks have been performed.Methods inherited from class org.elasticsearch.xpack.esql.enrich.AbstractLookupService
getThreadContext, lookupAsync, sendChildRequest, termQueryList
-
Field Details
-
LOOKUP_ACTION_NAME
- See Also:
-
-
Constructor Details
-
LookupFromIndexService
public LookupFromIndexService(ClusterService clusterService, AbstractLookupService.LookupShardContextFactory lookupShardContextFactory, TransportService transportService, BigArrays bigArrays, BlockFactory blockFactory)
-
-
Method Details
-
transportRequest
protected LookupFromIndexService.TransportRequest transportRequest(LookupFromIndexService.Request request, ShardId shardId) Description copied from class:AbstractLookupServiceConvert a request as sent toAbstractLookupService.lookupAsync(R, org.elasticsearch.tasks.CancellableTask, org.elasticsearch.action.ActionListener<java.util.List<org.elasticsearch.compute.data.Page>>)into a transport request after preflight checks have been performed.- Specified by:
transportRequestin classAbstractLookupService<LookupFromIndexService.Request,LookupFromIndexService.TransportRequest>
-
queryList
protected QueryList queryList(LookupFromIndexService.TransportRequest request, SearchExecutionContext context, Block inputBlock, @Nullable DataType inputDataType) Description copied from class:AbstractLookupServiceBuild a list of queries to perform inside the actual lookup.- Specified by:
queryListin classAbstractLookupService<LookupFromIndexService.Request,LookupFromIndexService.TransportRequest>
-
createLookupResponse
protected LookupFromIndexService.LookupResponse createLookupResponse(List<Page> pages, BlockFactory blockFactory) throws IOException Description copied from class:AbstractLookupServiceBuild the response.- Specified by:
createLookupResponsein classAbstractLookupService<LookupFromIndexService.Request,LookupFromIndexService.TransportRequest> - Throws:
IOException
-
readLookupResponse
protected org.elasticsearch.xpack.esql.enrich.AbstractLookupService.LookupResponse readLookupResponse(StreamInput in, BlockFactory blockFactory) throws IOException Description copied from class:AbstractLookupServiceRead the response from aStreamInput.- Specified by:
readLookupResponsein classAbstractLookupService<LookupFromIndexService.Request,LookupFromIndexService.TransportRequest> - Throws:
IOException
-