Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator.lookup

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

public final class EnrichQuerySourceOperator
extends SourceOperator

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.ShardLoad, SourceOperator.SourceOperatorFactory

Nested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator

Operator.OperatorFactory, Operator.Status

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_MAX_PAGE_SIZE

Fields inherited from interface org.elasticsearch.compute.operator.Operator

MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
EnrichQuerySourceOperator(BlockFactory blockFactory, int maxPageSize, LookupEnrichQueryGenerator queryList, Page originalPage, BlockOptimization blockOptimization, IndexedByShardId<? extends ShardContext> shardContexts, int shardId, SearchExecutionContext searchExecutionContext, Warnings warnings)

Method Summary

Modifier and Type	Method	Description
void	close()	notifies the operator that it won't be used anymore (i.e.
void	finish()	notifies the operator that it won't receive any more input pages
Page	getInputPage()	Get the input page (may be optimized, e.g., using dictionary block instead of ordinal block).
Page	getOutput()	returns non-null if output page available.
boolean	isFinished()	whether the operator has finished processing all input pages and made the corresponding output pages available

Methods inherited from class org.elasticsearch.compute.operator.SourceOperator

addInput, canProduceMoreDataWithoutExtraInput, needsInput, shardLoadDelta

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.elasticsearch.compute.operator.Operator

isBlocked, status

Field Details

DEFAULT_MAX_PAGE_SIZE

public static final int DEFAULT_MAX_PAGE_SIZE

See Also:

• Constant Field Values

Constructor Details

EnrichQuerySourceOperator

public EnrichQuerySourceOperator(BlockFactory blockFactory,
 int maxPageSize,
 LookupEnrichQueryGenerator queryList,
 Page originalPage,
 BlockOptimization blockOptimization,
 IndexedByShardId<? extends ShardContext> shardContexts,
 int shardId,
 SearchExecutionContext searchExecutionContext,
 Warnings warnings)

Method Details

getInputPage

public Page getInputPage()

Get the input page (may be optimized, e.g., using dictionary block instead of ordinal block). Exposed for testing to verify optimization behavior.

finish

public void finish()

Description copied from interface: Operator

notifies the operator that it won't receive any more input pages

isFinished

public boolean isFinished()

Description copied from interface: Operator

whether the operator has finished processing all input pages and made the corresponding output pages available

getOutput

public Page getOutput()

Description copied from interface: Operator

returns non-null if output page available. Only called when isFinished() == false

close

public void close()

Description copied from interface: Operator

notifies the operator that it won't be used anymore (i.e. none of the other methods called), and its resources can be cleaned up