Module org.elasticsearch.compute
Class EnrichQuerySourceOperator
java.lang.Object
org.elasticsearch.compute.operator.SourceOperator
org.elasticsearch.compute.operator.lookup.EnrichQuerySourceOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
Lookup document IDs for the input queries.
This operator will emit Pages consisting of a
DocVector and IntBlock of positions for each query of the input queries.
The position block will be used as keys to combine the extracted values by MergePositionsOperator.-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.compute.operator.SourceOperator
SourceOperator.SourceOperatorFactoryNested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator
Operator.OperatorFactory, Operator.Status -
Field Summary
FieldsFields inherited from interface org.elasticsearch.compute.operator.Operator
MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE -
Constructor Summary
ConstructorsConstructorDescriptionEnrichQuerySourceOperator(BlockFactory blockFactory, int maxPageSize, QueryList queryList, org.apache.lucene.index.IndexReader indexReader, Warnings warnings) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()notifies the operator that it won't be used anymore (i.e.voidfinish()notifies the operator that it won't receive any more input pagesreturns non-null if output page available.booleanwhether the operator has finished processing all input pages and made the corresponding output pages availableMethods inherited from class org.elasticsearch.compute.operator.SourceOperator
addInput, needsInput
-
Field Details
-
DEFAULT_MAX_PAGE_SIZE
public static final int DEFAULT_MAX_PAGE_SIZE- See Also:
-
-
Constructor Details
-
EnrichQuerySourceOperator
public EnrichQuerySourceOperator(BlockFactory blockFactory, int maxPageSize, QueryList queryList, org.apache.lucene.index.IndexReader indexReader, Warnings warnings)
-
-
Method Details
-
finish
public void finish()Description copied from interface:Operatornotifies the operator that it won't receive any more input pages -
isFinished
public boolean isFinished()Description copied from interface:Operatorwhether the operator has finished processing all input pages and made the corresponding output pages available -
getOutput
Description copied from interface:Operatorreturns non-null if output page available. Only called when isFinished() == false -
close
public void close()Description copied from interface:Operatornotifies the operator that it won't be used anymore (i.e. none of the other methods called), and its resources can be cleaned up
-