[CI] Auto commit changes from spotless

Author: elasticsearchmachine

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/ChangePointOperator.java

@@ -37,7 +37,9 @@ public class ChangePointOperator implements Operator {
 
     public static final int INPUT_VALUE_COUNT_LIMIT = 1000;
 
-    public record Factory(int metricChannel, Optional<Integer> partitionChannel, String sourceText, int sourceLine, int sourceColumn) implements OperatorFactory {
+    public record Factory(int metricChannel, Optional<Integer> partitionChannel, String sourceText, int sourceLine, int sourceColumn)
+        implements
+            OperatorFactory {
         @Override
         public Operator get(DriverContext driverContext) {
             return new ChangePointOperator(driverContext, metricChannel, partitionChannel, sourceText, sourceLine, sourceColumn);
@@ -63,7 +65,14 @@ public String describe() {
 
     // TODO: make org.elasticsearch.xpack.esql.core.tree.Source available here
     // (by modularizing esql-core) and use that instead of the individual fields.
-    public ChangePointOperator(DriverContext driverContext, int metricChannel, Optional<Integer> partitionChannel, String sourceText, int sourceLine, int sourceColumn) {
+    public ChangePointOperator(
+        DriverContext driverContext,
+        int metricChannel,
+        Optional<Integer> partitionChannel,
+        String sourceText,
+        int sourceLine,
+        int sourceColumn
+    ) {
         this.driverContext = driverContext;
         this.metricChannel = metricChannel;
         this.partitionChannel = partitionChannel;
@@ -230,7 +239,8 @@ private void insertChangePoints(Iterable<ChangeType> changeTypes) {
             lastPartitionFieldValue = currentPartitionFieldValue;
 
             try {
-                if (pageStartIndex <= changeType.changePoint() && changeType.changePoint() < pageStartIndex + inputPage.getPositionCount()) {
+                if (pageStartIndex <= changeType.changePoint()
+                    && changeType.changePoint() < pageStartIndex + inputPage.getPositionCount()) {
                     try (
                         BytesRefBlock.Builder changeTypeBlockBuilder = blockFactory.newBytesRefBlockBuilder(inputPage.getPositionCount());
                         DoubleBlock.Builder pvalueBlockBuilder = blockFactory.newDoubleBlockBuilder(inputPage.getPositionCount())
@@ -294,7 +304,10 @@ public String toString() {
     }
 
     private static String describe(int metricChannel, Optional<Integer> partitionChannel) {
-        return "ChangePointOperator[metricChannel=" + metricChannel + (partitionChannel.isPresent() ? ", partitionChannel=" + partitionChannel.get() : "") + "]";
+        return "ChangePointOperator[metricChannel="
+            + metricChannel
+            + (partitionChannel.isPresent() ? ", partitionChannel=" + partitionChannel.get() : "")
+            + "]";
     }
 
     private Warnings warnings(boolean onlyWarnings) {

x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/operator/ChangePointByOperatorTests.java

@@ -30,7 +30,7 @@ public class ChangePointByOperatorTests extends OperatorTestCase {
     @Override
     protected SourceOperator simpleInput(BlockFactory blockFactory, int size) {
         // size must be in [25, 1000] for ChangePoint to function correctly and detect the step change.
-        size = 25;//Math.clamp(size, 25, 1000);
+        size = 25;// Math.clamp(size, 25, 1000);
         List<Tuple<Long, BytesRef>> data = new ArrayList<>(size);
         for (int i = 0; i < size; i++) {  // step change 0 -> 100
             data.add(Tuple.tuple(i < size / 2 ? randomLongBetween(0, 3) : randomLongBetween(100, 103), new BytesRef("prod")));
@@ -81,7 +81,7 @@ protected void assertSimpleOutput(List<Page> input, List<Page> output) {
 
     @Override
     protected Operator.OperatorFactory simple() {
-        return new ChangePointOperator.Factory(0, Optional.of(1), null,0, 0);
+        return new ChangePointOperator.Factory(0, Optional.of(1), null, 0, 0);
     }
 
     @Override

x-pack/plugin/esql/compute/test/src/main/java/org/elasticsearch/compute/test/AbstractBlockSourceOperator.java

@@ -10,7 +10,6 @@
 import org.elasticsearch.compute.data.BlockFactory;
 import org.elasticsearch.compute.data.Page;
 import org.elasticsearch.compute.operator.SourceOperator;
-import org.elasticsearch.test.ESTestCase;
 
 /**
  * An abstract source operator. Implementations of this operator produce pages with a random

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/parser/LogicalPlanBuilder.java

@@ -479,7 +479,9 @@ public PlanFactory visitChangePointCommand(EsqlBaseParser.ChangePointCommandCont
         Source src = source(ctx);
         Attribute value = visitQualifiedName(ctx.value);
         Attribute key = ctx.key == null ? new UnresolvedAttribute(src, "@timestamp") : visitQualifiedName(ctx.key);
-        Attribute partitionField = ctx.partitionField == null ? new UnresolvedAttribute(src, "partition") : visitQualifiedName(ctx.partitionField);
+        Attribute partitionField = ctx.partitionField == null
+            ? new UnresolvedAttribute(src, "partition")
+            : visitQualifiedName(ctx.partitionField);
         Attribute targetType = new ReferenceAttribute(
             src,
             ctx.targetType == null ? "type" : visitQualifiedName(ctx.targetType).name(),

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plan/logical/ChangePoint.java

@@ -51,7 +51,15 @@ public class ChangePoint extends UnaryPlan implements SurrogateLogicalPlan, Post
 
     private List<Attribute> output;
 
-    public ChangePoint(Source source, LogicalPlan child, Attribute value, Attribute key, Attribute partitionField, Attribute targetType, Attribute targetPvalue) {
+    public ChangePoint(
+        Source source,
+        LogicalPlan child,
+        Attribute value,
+        Attribute key,
+        Attribute partitionField,
+        Attribute targetType,
+        Attribute targetPvalue
+    ) {
         super(source, child);
         this.value = value;
         this.key = key;
@@ -141,26 +149,26 @@ private Order order() {
     public LogicalPlan surrogate() {
         Order keyOrder = order();
 
-//        // The first Limit of N+1 data points is necessary to generate a possible warning,
-//        Limit limit = new Limit(
-//            source(),
-//            new Literal(Source.EMPTY, ChangePointOperator.INPUT_VALUE_COUNT_LIMIT + 1, DataType.INTEGER),
-//            orderBy
-//        );
+        // // The first Limit of N+1 data points is necessary to generate a possible warning,
+        // Limit limit = new Limit(
+        // source(),
+        // new Literal(Source.EMPTY, ChangePointOperator.INPUT_VALUE_COUNT_LIMIT + 1, DataType.INTEGER),
+        // orderBy
+        // );
 
         TopN topN = new TopN(
             source(),
             child(),
-            null,//partitionField,
+            null,// partitionField,
             List.of(keyOrder),
             new Literal(Source.EMPTY, ChangePointOperator.INPUT_VALUE_COUNT_LIMIT, DataType.INTEGER)
         );
 
-
         ChangePoint changePoint = new ChangePoint(source(), topN, value, key, partitionField, targetType, targetPvalue);
         return changePoint;
-//        // The second Limit of N data points is to truncate the output.
-//        return new Limit(source(), new Literal(Source.EMPTY, ChangePointOperator.INPUT_VALUE_COUNT_LIMIT, DataType.INTEGER), changePoint);
+        // // The second Limit of N data points is to truncate the output.
+        // return new Limit(source(), new Literal(Source.EMPTY, ChangePointOperator.INPUT_VALUE_COUNT_LIMIT, DataType.INTEGER),
+        // changePoint);
     }
 
     @Override

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plan/logical/TopN.java

@@ -11,7 +11,6 @@
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
 import org.elasticsearch.xpack.esql.core.capabilities.Resolvables;
-import org.elasticsearch.xpack.esql.core.expression.Attribute;
 import org.elasticsearch.xpack.esql.core.expression.Expression;
 import org.elasticsearch.xpack.esql.core.tree.NodeInfo;
 import org.elasticsearch.xpack.esql.core.tree.Source;

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plan/physical/TopNExec.java

@@ -39,7 +39,14 @@ public class TopNExec extends UnaryExec implements EstimatesRowSize {
      */
     private final Integer estimatedRowSize;
 
-    public TopNExec(Source source, PhysicalPlan child, Expression partitionField, List<Order> order, Expression limit, Integer estimatedRowSize) {
+    public TopNExec(
+        Source source,
+        PhysicalPlan child,
+        Expression partitionField,
+        List<Order> order,
+        Expression limit,
+        Integer estimatedRowSize
+    ) {
         super(source, child);
         this.partitionField = partitionField;
         this.order = order;

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

@@ -815,7 +815,9 @@ private PhysicalOperation planChangePoint(ChangePointExec changePoint, LocalExec
         return source.with(
             new ChangePointOperator.Factory(
                 layout.get(changePoint.value().id()).channel(),
-                changePoint.partitionField().typeResolved().resolved() ? Optional.of(layout.get(changePoint.partitionField().id()).channel()) : Optional.empty(),
+                changePoint.partitionField().typeResolved().resolved()
+                    ? Optional.of(layout.get(changePoint.partitionField().id()).channel())
+                    : Optional.empty(),
                 changePoint.sourceText(),
                 changePoint.sourceLocation().getLineNumber(),
                 changePoint.sourceLocation().getColumnNumber()

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/plan/logical/TopNSerializationTests.java

@@ -46,7 +46,10 @@ protected TopN mutateInstance(TopN instance) throws IOException {
         Expression limit = instance.limit();
         switch (between(0, 3)) {
             case 0 -> child = randomValueOtherThan(child, () -> randomChild(0));
-            case 1 -> partitionField = randomValueOtherThan(partitionField, () -> new Literal(randomSource(), randomAlphaOfLengthBetween(1, 10), DataType.KEYWORD));
+            case 1 -> partitionField = randomValueOtherThan(
+                partitionField,
+                () -> new Literal(randomSource(), randomAlphaOfLengthBetween(1, 10), DataType.KEYWORD)
+            );
             case 2 -> order = randomValueOtherThan(order, TopNSerializationTests::randomOrders);
             case 3 -> limit = randomValueOtherThan(limit, AbstractExpressionSerializationTests::randomChild);
         }

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/plan/physical/TopNExecSerializationTests.java

@@ -48,7 +48,10 @@ protected TopNExec mutateInstance(TopNExec instance) throws IOException {
                 estimatedRowSize,
                 AbstractPhysicalPlanSerializationTests::randomEstimatedRowSize
             );
-            case 4 -> partitionField = randomValueOtherThan(partitionField, () -> new Literal(randomSource(), randomAlphaOfLengthBetween(1, 10), DataType.KEYWORD));
+            case 4 -> partitionField = randomValueOtherThan(
+                partitionField,
+                () -> new Literal(randomSource(), randomAlphaOfLengthBetween(1, 10), DataType.KEYWORD)
+            );
             default -> throw new UnsupportedOperationException();
         }
         return new TopNExec(instance.source(), child, partitionField, order, limit, estimatedRowSize);