Module org.elasticsearch.compute
Class RrfScoreEvalOperator
java.lang.Object
org.elasticsearch.compute.operator.AbstractPageMappingOperator
org.elasticsearch.compute.operator.RrfScoreEvalOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
Updates the score column with new scores using the RRF formula.
Receives the position of the score and fork columns.
The new score we assign to each row is equal to
1 / (rank_constant + row_number).
We use the fork discriminator column to determine the row_number for each row.-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from class org.elasticsearch.compute.operator.AbstractPageMappingOperator
AbstractPageMappingOperator.StatusNested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator
Operator.OperatorFactory -
Field Summary
Fields inherited from interface org.elasticsearch.compute.operator.Operator
MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.elasticsearch.compute.operator.AbstractPageMappingOperator
addInput, close, finish, getOutput, isFinished, needsInput, status, status
-
Constructor Details
-
RrfScoreEvalOperator
public RrfScoreEvalOperator(int forkPosition, int scorePosition)
-
-
Method Details
-
process
- Specified by:
processin classAbstractPageMappingOperator
-
toString
- Specified by:
toStringin classAbstractPageMappingOperator
-