Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator

Class LocalSourceOperator

java.lang.Object

org.elasticsearch.compute.operator.SourceOperator

org.elasticsearch.compute.operator.LocalSourceOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, Releasable

Direct Known Subclasses:

ShowOperator

public class LocalSourceOperator
extends SourceOperator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	LocalSourceOperator.BlockSupplier
static interface	LocalSourceOperator.ListSupplier
static final record	LocalSourceOperator.LocalSourceFactory
static interface	LocalSourceOperator.ObjectSupplier
static interface	LocalSourceOperator.PageSupplier

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
protected final LocalSourceOperator.PageSupplier	supplier

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

MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
LocalSourceOperator(BlockFactory blockFactory, LocalSourceOperator.ListSupplier listSupplier)
LocalSourceOperator(BlockFactory blockFactory, LocalSourceOperator.ObjectSupplier objectSupplier)
LocalSourceOperator(LocalSourceOperator.BlockSupplier blockSupplier)
LocalSourceOperator(LocalSourceOperator.PageSupplier pageSupplier)

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	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
String	toString()

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, wait, wait, wait

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

isBlocked, status, tryPromote

Field Details

supplier

protected final LocalSourceOperator.PageSupplier supplier

Constructor Details

LocalSourceOperator

public LocalSourceOperator(BlockFactory blockFactory,
 LocalSourceOperator.ObjectSupplier objectSupplier)

LocalSourceOperator

public LocalSourceOperator(BlockFactory blockFactory,
 LocalSourceOperator.ListSupplier listSupplier)

LocalSourceOperator

public LocalSourceOperator(LocalSourceOperator.BlockSupplier blockSupplier)

LocalSourceOperator

public LocalSourceOperator(LocalSourceOperator.PageSupplier pageSupplier)

Method Details

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

toString

public String toString()

Overrides:

toString in class Object