Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator

Class RowInTableLookupOperator

java.lang.Object

org.elasticsearch.compute.operator.AbstractPageMappingToIteratorOperator

org.elasticsearch.compute.operator.RowInTableLookupOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, Releasable

public class RowInTableLookupOperator
extends AbstractPageMappingToIteratorOperator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	RowInTableLookupOperator.Factory	Factory for RowInTableLookupOperator.
static final record	RowInTableLookupOperator.Key

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
RowInTableLookupOperator(BlockFactory blockFactory, RowInTableLookupOperator.Key[] keys, int[] blockMapping)

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

RowInTableLookupOperator

public RowInTableLookupOperator(BlockFactory blockFactory,
 RowInTableLookupOperator.Key[] keys,
 int[] blockMapping)

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

toString

public String toString()

Specified by:

toString 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