Package org.elasticsearch.xpack.esql.inference.completion

Class CompletionOperator

java.lang.Object

org.elasticsearch.compute.operator.AsyncOperator<InferenceOperator.OngoingInferenceResult>

org.elasticsearch.xpack.esql.inference.InferenceOperator

org.elasticsearch.xpack.esql.inference.completion.CompletionOperator

All Implemented Interfaces:

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

public class CompletionOperator
extends InferenceOperator

CompletionOperator is an InferenceOperator that performs inference using prompt-based model (e.g., text completion). It evaluates a prompt expression for each input row, constructs inference requests, and emits the model responses as output.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	CompletionOperator.Factory	Factory for creating CompletionOperator instances.

Nested classes/interfaces inherited from class org.elasticsearch.xpack.esql.inference.InferenceOperator

InferenceOperator.BulkInferenceOperation, InferenceOperator.BulkInferenceRequestItem, InferenceOperator.BulkInferenceRequestItemIterator, InferenceOperator.BulkInferenceResponseItem, InferenceOperator.OngoingInferenceResult, InferenceOperator.OutputBuilder

Nested classes/interfaces inherited from class org.elasticsearch.compute.operator.AsyncOperator

AsyncOperator.Status

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

Operator.OperatorFactory

Field Summary

Fields inherited from class org.elasticsearch.xpack.esql.inference.InferenceOperator

DEFAULT_MAX_OUTSTANDING_PAGES, DEFAULT_MAX_OUTSTANDING_REQUESTS

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

MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE

Method Summary

Modifier and Type	Method	Description
String	toString()

Methods inherited from class org.elasticsearch.xpack.esql.inference.InferenceOperator

doClose, getOutput, inferenceId, performAsync, releaseFetchedOnAnyThread

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

addInput, canProduceMoreDataWithoutExtraInput, close, fetchFromBuffer, finish, isBlocked, isFinished, needsInput, releasePageOnAnyThread, status, status

Methods inherited from class java.lang.Object

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

Method Details

toString

public String toString()

Overrides:

toString in class Object