Module org.elasticsearch.compute

Package org.elasticsearch.compute.lucene.read

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

public class ValuesSourceReaderOperator
extends AbstractPageMappingToIteratorOperator

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 Classes

Modifier and Type	Class	Description
static interface	ValuesSourceReaderOperator.BuildLoader	Builds a ValuesSourceReaderOperator.LoaderAndConverter for a given shard.
static interface	ValuesSourceReaderOperator.ConverterEvaluator	Evaluator for any type conversions that must be performed on load.
static interface	ValuesSourceReaderOperator.ConverterFactory
static final record	ValuesSourceReaderOperator.Factory	Creates a factory for ValuesSourceReaderOperator.
static final record	ValuesSourceReaderOperator.FieldInfo	Configuration for a field to load.
protected class	ValuesSourceReaderOperator.FieldWork
static class	ValuesSourceReaderOperator.LoaderAndConverter
static final record	ValuesSourceReaderOperator.ShardContext

Nested classes/interfaces inherited from class org.elasticsearch.compute.operator.AbstractPageMappingToIteratorOperator

AbstractPageMappingToIteratorOperator.Status

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

Operator.OperatorFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final ValuesSourceReaderOperator.LoaderAndConverter	LOAD_CONSTANT_NULLS	Singleton to load constant nulls.

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

MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
ValuesSourceReaderOperator(DriverContext driverContext, long jumboBytes, List<ValuesSourceReaderOperator.FieldInfo> fields, IndexedByShardId<? extends ValuesSourceReaderOperator.ShardContext> shardContexts, boolean reuseColumnLoaders, int docChannel, double sourceReservationFactor, int docSequenceBytesRefFieldThreshold)	Creates a new extractor

Method Summary

Modifier and Type	Method	Description
void	close()	notifies the operator that it won't be used anymore (i.e.
static ValuesSourceReaderOperator.LoaderAndConverter	load(BlockLoader loader)	Loads directly from the loader.
static ValuesSourceReaderOperator.LoaderAndConverter	loadAndConvert(BlockLoader loader, ValuesSourceReaderOperator.ConverterFactory converter)	Loads from the loader and then converts the values using the converter.
protected org.elasticsearch.core.ReleasableIterator<Page>	receive(Page page)	Build and Iterator of results for a new page.
protected ValuesSourceReaderOperatorStatus	status(long processNanos, int pagesReceived, int pagesEmitted, long rowsReceived, long rowsEmitted)
String	toString()

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

addInput, appendBlockArrays, appendBlocks, canProduceMoreDataWithoutExtraInput, finish, getOutput, isFinished, needsInput, status

Methods inherited from class java.lang.Object

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

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

isBlocked

Field Details

LOAD_CONSTANT_NULLS

public static final ValuesSourceReaderOperator.LoaderAndConverter LOAD_CONSTANT_NULLS

Singleton to load constant nulls.

Constructor Details

ValuesSourceReaderOperator

public ValuesSourceReaderOperator(DriverContext driverContext,
 long jumboBytes,
 List<ValuesSourceReaderOperator.FieldInfo> fields,
 IndexedByShardId<? extends ValuesSourceReaderOperator.ShardContext> shardContexts,
 boolean reuseColumnLoaders,
 int docChannel,
 double sourceReservationFactor,
 int docSequenceBytesRefFieldThreshold)

Creates a new extractor

Parameters:

fields - fields to load

docChannel - the channel containing the shard, leaf/segment and doc id

Method Details

load

public static ValuesSourceReaderOperator.LoaderAndConverter load(BlockLoader loader)

Loads directly from the loader.

loadAndConvert

public static ValuesSourceReaderOperator.LoaderAndConverter loadAndConvert(BlockLoader loader,
 ValuesSourceReaderOperator.ConverterFactory converter)

Loads from the loader and then converts the values using the converter.

receive

protected org.elasticsearch.core.ReleasableIterator<Page> receive(Page page)

Description copied from class: AbstractPageMappingToIteratorOperator

Build and Iterator of results for a new page.

Specified by:

receive in class AbstractPageMappingToIteratorOperator

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

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Operator

Specified by:

close in interface org.elasticsearch.core.Releasable

Overrides:

close in class AbstractPageMappingToIteratorOperator

toString

public String toString()

Specified by:

toString in class AbstractPageMappingToIteratorOperator

status

protected ValuesSourceReaderOperatorStatus status(long processNanos,
 int pagesReceived,
 int pagesEmitted,
 long rowsReceived,
 long rowsEmitted)

Overrides:

status in class AbstractPageMappingToIteratorOperator