Class StreamingLookupFromIndexOperator
java.lang.Object
org.elasticsearch.xpack.esql.enrich.StreamingLookupFromIndexOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
Streaming version of LookupFromIndexOperator.
Uses BidirectionalBatchExchange to stream pages to server and receive results.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classStatus 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
ConstructorsConstructorDescriptionStreamingLookupFromIndexOperator(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
-
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:
needsInputin interfaceOperator
-
addInput
-
getOutput
-
finish
public void finish() -
isFinished
public boolean isFinished()- Specified by:
isFinishedin interfaceOperator
-
canProduceMoreDataWithoutExtraInput
public boolean canProduceMoreDataWithoutExtraInput()- Specified by:
canProduceMoreDataWithoutExtraInputin interfaceOperator
-
isBlocked
-
close
public void close() -
status
-
toString
-