Skip to content

Commit 56d623e

Browse files
committed
Improve RerankFunction tests.
1 parent 0b71d74 commit 56d623e

File tree

14 files changed

+354
-58
lines changed

14 files changed

+354
-58
lines changed

docs/reference/query-languages/esql/_snippets/functions/description/rerank.md

Lines changed: 6 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

docs/reference/query-languages/esql/_snippets/functions/functionNamedParams/rerank.md

Lines changed: 7 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

docs/reference/query-languages/esql/_snippets/functions/layout/rerank.md

Lines changed: 32 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

docs/reference/query-languages/esql/_snippets/functions/parameters/rerank.md

Lines changed: 13 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

docs/reference/query-languages/esql/_snippets/functions/types/rerank.md

Lines changed: 11 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

docs/reference/query-languages/esql/images/functions/rerank.svg

Lines changed: 1 addition & 0 deletions
Loading

docs/reference/query-languages/esql/kibana/definition/functions/rerank.json

Lines changed: 110 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

docs/reference/query-languages/esql/kibana/docs/functions/rerank.md

Lines changed: 5 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/expression/function/EsqlFunctionRegistry.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@
5252
import org.elasticsearch.xpack.esql.expression.function.fulltext.Term;
5353
import org.elasticsearch.xpack.esql.expression.function.grouping.Bucket;
5454
import org.elasticsearch.xpack.esql.expression.function.grouping.Categorize;
55+
import org.elasticsearch.xpack.esql.expression.function.inference.RerankFunction;
5556
import org.elasticsearch.xpack.esql.expression.function.scalar.conditional.Case;
5657
import org.elasticsearch.xpack.esql.expression.function.scalar.conditional.Greatest;
5758
import org.elasticsearch.xpack.esql.expression.function.scalar.conditional.Least;
@@ -487,7 +488,8 @@ private static FunctionDefinition[][] snapshotFunctions() {
487488
def(LastOverTime.class, LastOverTime::withUnresolvedTimestamp, "last_over_time"),
488489
def(FirstOverTime.class, FirstOverTime::withUnresolvedTimestamp, "first_over_time"),
489490
def(Term.class, bi(Term::new), "term"),
490-
def(Knn.class, tri(Knn::new), "knn") } };
491+
def(Knn.class, tri(Knn::new), "knn"),
492+
def(RerankFunction.class, tri(RerankFunction::new), "rerank") } };
491493
}
492494

493495
public EsqlFunctionRegistry snapshotRegistry() {

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/expression/function/inference/InferenceFunction.java

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -7,13 +7,10 @@
77

88
package org.elasticsearch.xpack.esql.expression.function.inference;
99

10-
import org.elasticsearch.logging.LogManager;
11-
import org.elasticsearch.xpack.esql.core.InvalidArgumentException;
1210
import org.elasticsearch.xpack.esql.core.expression.Attribute;
1311
import org.elasticsearch.xpack.esql.core.expression.Expression;
1412
import org.elasticsearch.xpack.esql.core.expression.Literal;
1513
import org.elasticsearch.xpack.esql.core.expression.MapExpression;
16-
import org.elasticsearch.xpack.esql.core.expression.TypeResolutions;
1714
import org.elasticsearch.xpack.esql.core.expression.function.Function;
1815
import org.elasticsearch.xpack.esql.core.tree.Source;
1916
import org.elasticsearch.xpack.esql.core.type.DataType;
@@ -47,12 +44,12 @@ public Expression options() {
4744

4845
public abstract List<Attribute> temporaryAttributes();
4946

50-
protected Expression readOption(String optionName, TypeResolutions.ParamOrdinal optionParamOrd, Expression options) {
51-
return readOption(optionName, optionParamOrd, options, Literal.NULL);
47+
protected Expression readOption(String optionName, Expression options) {
48+
return readOption(optionName, options, Literal.NULL);
5249
}
5350

54-
protected Expression readOption(String optionName, TypeResolutions.ParamOrdinal optionParamOrd, Expression options, Expression defaultValue) {
55-
if (options != null && options.dataType() != DataType.NULL && options instanceof MapExpression mapOptions) {
51+
protected Expression readOption(String optionName, Expression options, Expression defaultValue) {
52+
if (options != null && options.dataType() != DataType.NULL && options instanceof MapExpression mapOptions) {
5653
return mapOptions.getOrDefault(optionName, defaultValue);
5754
}
5855

@@ -65,7 +62,7 @@ protected TypeResolution resolveType() {
6562
return new TypeResolution("Unresolved children");
6663
}
6764

68-
return resolveOptions().and(resolveParams());
65+
return resolveParams().and(resolveOptions());
6966
}
7067

7168
protected abstract TypeResolution resolveParams();

0 commit comments

Comments
 (0)