first chicken_score PoC

Author: tteofili

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

@@ -446,8 +446,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(ChickenScore.class, uni(ChickenScore::new), "chicken_score"),
                 def(LastOverTime.class, LastOverTime::withUnresolvedTimestamp, "last_over_time"),
+                def(ChickenScore.class, uni(ChickenScore::new), "chicken_score"),
                 def(Term.class, bi(Term::new), "term") } };
     }
 

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

@@ -227,9 +227,9 @@ private static void checkFullTextQueryFunctions(LogicalPlan plan, Failures failu
             );
             checkFullTextFunctionsParents(condition, failures);
         } else {
-            plan.forEachExpression(FullTextFunction.class, ftf -> {
+            /*plan.forEachExpression(FullTextFunction.class, ftf -> {
                 failures.add(fail(ftf, "[{}] {} is only supported in WHERE commands", ftf.functionName(), ftf.functionType()));
-            });
+            });*/
         }
     }
 

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

@@ -27,9 +27,6 @@ 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);
     }

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/planner/LocalExecutionPlanner.java

@@ -461,7 +461,7 @@ private PhysicalOperation planEval(EvalExec eval, LocalExecutionPlannerContext c
         PhysicalOperation source = plan(eval.child(), context);
 
         for (Alias field : eval.fields()) {
-            var evaluatorSupplier = EvalMapper.toEvaluator(context.foldCtx(), field.child(), source.layout);
+            var evaluatorSupplier = EvalMapper.toEvaluator(context.foldCtx(), field.child(), source.layout, shardContexts);
             Layout.Builder layout = source.layout.builder();
             layout.append(field.toAttribute());
             source = source.with(new EvalOperatorFactory(evaluatorSupplier), layout.build());