Package org.elasticsearch.xpack.esql.inference.rerank

Class RerankOperator

java.lang.Object

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

org.elasticsearch.xpack.esql.inference.InferenceOperator

org.elasticsearch.xpack.esql.inference.rerank.RerankOperator

All Implemented Interfaces:

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

public class RerankOperator
extends InferenceOperator

RerankOperator is an InferenceOperator that computes relevance scores for rows using a reranking model. It evaluates a row encoder expression for each input row, batches them together, and sends them to the reranking service with a query text to obtain relevance scores.

Nested Class Summary

Nested Classes

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

Modifier and Type	Field	Description
static final int	DEFAULT_BATCH_SIZE

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

Field Details

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

See Also:

• Constant Field Values

Method Details

toString

public String toString()

Overrides:

toString in class Object