[CI] Auto commit changes from spotless

Author: elasticsearchmachine

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

@@ -36,7 +36,9 @@ public class ChangePointOperator implements Operator {
 
     public static final int INPUT_VALUE_COUNT_LIMIT = 1000;
 
-    public record Factory(int metricChannel, int partitionChannel, String sourceText, int sourceLine, int sourceColumn) implements OperatorFactory {
+    public record Factory(int metricChannel, int partitionChannel, String sourceText, int sourceLine, int sourceColumn)
+        implements
+            OperatorFactory {
         @Override
         public Operator get(DriverContext driverContext) {
             return new ChangePointOperator(driverContext, metricChannel, partitionChannel, sourceText, sourceLine, sourceColumn);
@@ -62,7 +64,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, int partitionChannel, String sourceText, int sourceLine, int sourceColumn) {
+    public ChangePointOperator(
+        DriverContext driverContext,
+        int metricChannel,
+        int partitionChannel,
+        String sourceText,
+        int sourceLine,
+        int sourceColumn
+    ) {
         this.driverContext = driverContext;
         this.metricChannel = metricChannel;
         this.partitionChannel = partitionChannel;
@@ -229,7 +238,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())

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

@@ -397,7 +397,9 @@ public void addInput(Page page) {
                 spareKeysPreAllocSize = Math.max(spare.keys.length(), spareKeysPreAllocSize / 2);
                 spareValuesPreAllocSize = Math.max(spare.values.length(), spareValuesPreAllocSize / 2);
 
-                String partition = partitionByChannel.isPresent() ? page.getBlock(partitionByChannel.get()).asVector().filter(i).toString() : "-default-";
+                String partition = partitionByChannel.isPresent()
+                    ? page.getBlock(partitionByChannel.get()).asVector().filter(i).toString()
+                    : "-default-";
                 Queue inputQueue = inputQueues.get(partition);
                 if (inputQueue == null) {
                     inputQueues.put(partition, inputQueue = new Queue(topCount));

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, "partitionField") : visitQualifiedName(ctx.partitionField);
+        Attribute partitionField = ctx.partitionField == null
+            ? new UnresolvedAttribute(src, "partitionField")
+            : 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,12 +149,12 @@ 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(),
@@ -156,11 +164,11 @@ public LogicalPlan surrogate() {
             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, List<Order> order, Expression limit, Integer estimatedRowSize, Expression partitionField) {
+    public TopNExec(
+        Source source,
+        PhysicalPlan child,
+        List<Order> order,
+        Expression limit,
+        Integer estimatedRowSize,
+        Expression partitionField
+    ) {
         super(source, child);
         this.order = order;
         this.limit = limit;

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, order, limit, estimatedRowSize, partitionField);