Package org.elasticsearch.xpack.esql.enrich

Class StreamingLookupFromIndexOperator

java.lang.Object

org.elasticsearch.xpack.esql.enrich.StreamingLookupFromIndexOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, org.elasticsearch.core.Releasable

public class StreamingLookupFromIndexOperator
extends Object
implements Operator

Streaming version of LookupFromIndexOperator. Uses BidirectionalBatchExchange to stream pages to server and receive results.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamingLookupFromIndexOperator.StreamingLookupStatus	Status for StreamingLookupFromIndexOperator.

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

Operator.OperatorFactory, Operator.Status

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

StreamingLookupFromIndexOperator(DriverContext driverContext, List<MatchConfig> matchFields, String sessionId, CancellableTask parentTask, int maxOutstandingRequests, LookupFromIndexService lookupService, String lookupIndexPattern, String lookupIndex, List<NamedExpression> loadFields, Source source, PhysicalPlan rightPreJoinPlan, Expression joinOnConditions, int exchangeBufferSize, boolean profile, Configuration configuration)

Method Summary

Modifier and Type	Method	Description
void	addInput(Page page)
boolean	canProduceMoreDataWithoutExtraInput()
void	close()
void	finish()
Page	getOutput()
IsBlockedResult	isBlocked()
boolean	isFinished()
boolean	needsInput()
Operator.Status	status()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

StreamingLookupFromIndexOperator

public StreamingLookupFromIndexOperator(DriverContext driverContext,
 List<MatchConfig> matchFields,
 String sessionId,
 CancellableTask parentTask,
 int maxOutstandingRequests,
 LookupFromIndexService lookupService,
 String lookupIndexPattern,
 String lookupIndex,
 List<NamedExpression> loadFields,
 Source source,
 PhysicalPlan rightPreJoinPlan,
 Expression joinOnConditions,
 int exchangeBufferSize,
 boolean profile,
 @Nullable
 Configuration configuration)

Method Details

needsInput

public boolean needsInput()

Specified by:

needsInput in interface Operator

addInput

public void addInput(Page page)

Specified by:

addInput in interface Operator

getOutput

public Page getOutput()

Specified by:

getOutput in interface Operator

finish

public void finish()

Specified by:

finish in interface Operator

isFinished

public boolean isFinished()

Specified by:

isFinished in interface Operator

canProduceMoreDataWithoutExtraInput

public boolean canProduceMoreDataWithoutExtraInput()

Specified by:

canProduceMoreDataWithoutExtraInput in interface Operator

isBlocked

public IsBlockedResult isBlocked()

Specified by:

isBlocked in interface Operator

close

public void close()

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

status

public Operator.Status status()

Specified by:

status in interface Operator

toString

public String toString()

Overrides:

toString in class Object