Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator

Class ColumnLoadOperator

java.lang.Object

org.elasticsearch.compute.operator.AbstractPageMappingToIteratorOperator

org.elasticsearch.compute.operator.ColumnLoadOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, Releasable

public class ColumnLoadOperator
extends AbstractPageMappingToIteratorOperator

Looks up values from a provided Block and merged them into each Page.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ColumnLoadOperator.Factory	Factory for ColumnLoadOperator.
static final record	ColumnLoadOperator.Values

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 inherited from interface org.elasticsearch.compute.operator.Operator

MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
ColumnLoadOperator(ColumnLoadOperator.Values values, int positionsOrd)

Method Summary

Modifier and Type	Method	Description
void	close()	notifies the operator that it won't be used anymore (i.e.
protected ReleasableIterator<Page>	receive(Page page)	Build and Iterator of results for a new page.
String	toString()

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

addInput, appendBlockArrays, appendBlocks, canProduceMoreDataWithoutExtraInput, finish, getOutput, isFinished, needsInput, status, 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, tryPromote

Constructor Details

ColumnLoadOperator

public ColumnLoadOperator(ColumnLoadOperator.Values values,
 int positionsOrd)

Method Details

receive

protected 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 Releasable

Overrides:

close in class AbstractPageMappingToIteratorOperator

toString

public String toString()

Specified by:

toString in class AbstractPageMappingToIteratorOperator