Module org.elasticsearch.compute
Class ValuesSourceReaderOperator
java.lang.Object
org.elasticsearch.compute.operator.AbstractPageMappingToIteratorOperator
org.elasticsearch.compute.lucene.read.ValuesSourceReaderOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
Operator that extracts doc_values from a Lucene index out of pages that have been produced by
LuceneSourceOperator
and outputs them to a new column.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final recordCreates a factory forValuesSourceReaderOperator.static final recordConfiguration for a field to load.protected classstatic final recordNested classes/interfaces inherited from class org.elasticsearch.compute.operator.AbstractPageMappingToIteratorOperator
AbstractPageMappingToIteratorOperator.StatusNested 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
ConstructorsConstructorDescriptionValuesSourceReaderOperator(BlockFactory blockFactory, long jumboBytes, List<ValuesSourceReaderOperator.FieldInfo> fields, List<ValuesSourceReaderOperator.ShardContext> shardContexts, int docChannel) Creates a new extractor -
Method Summary
Modifier and TypeMethodDescriptionprotected org.elasticsearch.core.ReleasableIterator<Page> Build and Iterator of results for a new page.protected ValuesSourceReaderOperatorStatusstatus(long processNanos, int pagesReceived, int pagesEmitted, long rowsReceived, long rowsEmitted) toString()Methods inherited from class org.elasticsearch.compute.operator.AbstractPageMappingToIteratorOperator
addInput, appendBlockArrays, appendBlocks, close, finish, getOutput, isFinished, needsInput, status
-
Constructor Details
-
ValuesSourceReaderOperator
public ValuesSourceReaderOperator(BlockFactory blockFactory, long jumboBytes, List<ValuesSourceReaderOperator.FieldInfo> fields, List<ValuesSourceReaderOperator.ShardContext> shardContexts, int docChannel) Creates a new extractor- Parameters:
fields- fields to loaddocChannel- the channel containing the shard, leaf/segment and doc id
-
-
Method Details
-
receive
Description copied from class:AbstractPageMappingToIteratorOperatorBuild and Iterator of results for a new page.- Specified by:
receivein classAbstractPageMappingToIteratorOperator
-
toString
- Specified by:
toStringin classAbstractPageMappingToIteratorOperator
-
status
protected ValuesSourceReaderOperatorStatus status(long processNanos, int pagesReceived, int pagesEmitted, long rowsReceived, long rowsEmitted) - Overrides:
statusin classAbstractPageMappingToIteratorOperator
-