Package org.elasticsearch.xpack.esql.inference.textembedding

Class TextEmbeddingOperator

java.lang.Object

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

org.elasticsearch.xpack.esql.inference.InferenceOperator

org.elasticsearch.xpack.esql.inference.textembedding.TextEmbeddingOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, Releasable

public class TextEmbeddingOperator
extends InferenceOperator

TextEmbeddingOperator is an InferenceOperator that performs text embedding inference. It evaluates a text expression for each input row, constructs text embedding inference requests, and emits the dense vector embeddings as output.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	TextEmbeddingOperator.Factory	Factory for creating TextEmbeddingOperator 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

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

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

tryPromote

Method Details

toString

public String toString()

Overrides:

toString in class Object