Merge

Author: tteofili

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlCapabilities.java

@@ -984,7 +984,12 @@ public enum Cap {
         /**
          * Support avg_over_time aggregation that gets evaluated per time-series
          */
-        AVG_OVER_TIME(Build.current().isSnapshot());
+        AVG_OVER_TIME(Build.current().isSnapshot()),
+
+        /**
+         * chicken_score ES|QL function
+         */
+        CHICKEN_SCORE(Build.current().isSnapshot());
 
         private final boolean enabled;
 

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

@@ -34,6 +34,7 @@
 import org.elasticsearch.xpack.esql.expression.function.aggregate.Top;
 import org.elasticsearch.xpack.esql.expression.function.aggregate.Values;
 import org.elasticsearch.xpack.esql.expression.function.aggregate.WeightedAvg;
+import org.elasticsearch.xpack.esql.expression.function.fulltext.ChickenScore;
 import org.elasticsearch.xpack.esql.expression.function.fulltext.Kql;
 import org.elasticsearch.xpack.esql.expression.function.fulltext.Match;
 import org.elasticsearch.xpack.esql.expression.function.fulltext.QueryString;
@@ -436,8 +437,8 @@ private static FunctionDefinition[][] snapshotFunctions() {
                 def(Rate.class, Rate::withUnresolvedTimestamp, "rate"),
                 def(MaxOverTime.class, uni(MaxOverTime::new), "max_over_time"),
                 def(AvgOverTime.class, uni(AvgOverTime::new), "avg_over_time"),
-                def(Term.class, bi(Term::new), "term") } };
-    }
+                def(ChickenScore.class, uni(ChickenScore::new), "chicken_score"),
+                def(Term.class, bi(Term::new), "term") } };}
 
     public EsqlFunctionRegistry snapshotRegistry() {
         if (Build.current().isSnapshot() == false) {

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

@@ -28,6 +28,9 @@ public static List<NamedWriteableRegistry.Entry> getNamedWriteables() {
         if (EsqlCapabilities.Cap.TERM_FUNCTION.isEnabled()) {
             entries.add(Term.ENTRY);
         }
+        if (EsqlCapabilities.Cap.CHICKEN_SCORE.isEnabled()) {
+            entries.add(ChickenScore.ENTRY);
+        }
 
         return Collections.unmodifiableList(entries);
     }