[CI] Auto commit changes from spotless

Author: elasticsearchmachine

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/planner/PlanConcurrencyCalculatorTests.java

@@ -30,38 +30,30 @@ public class PlanConcurrencyCalculatorTests extends ESTestCase {
 
     public void testSimpleLimit() {
         assertConcurrency("""
-                FROM x
-                | LIMIT 123
-                """,
-            123
-        );
+            FROM x
+            | LIMIT 123
+            """, 123);
     }
 
     public void testImplicitLimit() {
         assertConcurrency("""
             FROM x
-            """,
-            1000
-        );
+            """, 1000);
     }
 
     public void testStats() {
         assertConcurrency("""
             FROM x
             | STATS COUNT(salary)
-            """,
-            null
-        );
+            """, null);
     }
 
     public void testStatsWithLimit() {
         assertConcurrency("""
             FROM x
             | LIMIT 123
             | STATS COUNT(salary)
-            """,
-            123
-        );
+            """, 123);
     }
 
     public void testStatsWithSortBeforeLimit() {
@@ -70,9 +62,7 @@ public void testStatsWithSortBeforeLimit() {
             | SORT salary
             | LIMIT 123
             | STATS COUNT(salary)
-            """,
-            null
-        );
+            """, null);
     }
 
     public void testStatsWithSortAfterLimit() {
@@ -81,57 +71,34 @@ public void testStatsWithSortAfterLimit() {
             | SORT salary
             | LIMIT 123
             | STATS COUNT(salary)
-            """,
-            null
-        );
+            """, null);
     }
 
     public void testSort() {
         assertConcurrency("""
             FROM x
             | SORT salary
-            """,
-            null
-        );
+            """, null);
     }
 
-    private void assertConcurrency(
-        String query,
-        Integer expectedConcurrency
-    ) {
+    private void assertConcurrency(String query, Integer expectedConcurrency) {
         assertConcurrency(query, null, expectedConcurrency);
     }
 
-    private void assertConcurrency(
-        String query,
-        Integer concurrencyPragmaValue,
-        Integer expectedConcurrency
-    ) {
+    private void assertConcurrency(String query, Integer concurrencyPragmaValue, Integer expectedConcurrency) {
         Configuration configuration = concurrencyPragmaValue == null
             ? configuration(query)
             : configuration(
-                new QueryPragmas(
-                    Settings.builder()
-                        .put("max_concurrent_nodes_per_cluster", concurrencyPragmaValue)
-                        .build()
-                ),
+                new QueryPragmas(Settings.builder().put("max_concurrent_nodes_per_cluster", concurrencyPragmaValue).build()),
                 query
             );
-        Analyzer analyzer = analyzer(
-            loadMapping("mapping-basic.json", "test"), TEST_VERIFIER, configuration
-        );
+        Analyzer analyzer = analyzer(loadMapping("mapping-basic.json", "test"), TEST_VERIFIER, configuration);
         LogicalPlan logicalPlan = AnalyzerTestUtils.analyze(query, analyzer);
         PhysicalPlan physicalPlan = new Mapper().map(logicalPlan);
 
-        PhysicalPlan dataNodePlan = PlannerUtils.breakPlanBetweenCoordinatorAndDataNode(
-            physicalPlan,
-            configuration
-        ).v2();
+        PhysicalPlan dataNodePlan = PlannerUtils.breakPlanBetweenCoordinatorAndDataNode(physicalPlan, configuration).v2();
 
-        Integer actualConcurrency = PlanConcurrencyCalculator.INSTANCE.calculateNodesConcurrency(
-            dataNodePlan,
-            configuration
-        );
+        Integer actualConcurrency = PlanConcurrencyCalculator.INSTANCE.calculateNodesConcurrency(dataNodePlan, configuration);
 
         assertThat(actualConcurrency, equalTo(expectedConcurrency));
     }