spotless

Signed-off-by: Selina Song <[email protected]>

Author: Selina Song

core/src/main/java/org/opensearch/sql/calcite/CalciteRelNodeVisitor.java

@@ -569,7 +569,7 @@ public RelNode visitHead(Head node, CalcitePlanContext context) {
   public RelNode visitReverse(
       org.opensearch.sql.ast.tree.Reverse node, CalcitePlanContext context) {
     visitChildren(node, context);
-    
+
     RelCollation collation = context.relBuilder.peek().getTraitSet().getCollation();
     if (collation == null || collation == RelCollations.EMPTY) {
       // If no collation exists, use the traditional row_number approach
@@ -591,7 +591,7 @@ public RelNode visitReverse(
       RelCollation reversedCollation = PlanUtils.reverseCollation(collation);
       context.relBuilder.sort(reversedCollation);
     }
-    
+
     return context.relBuilder.peek();
   }
 

core/src/main/java/org/opensearch/sql/calcite/utils/PlanUtils.java

@@ -372,12 +372,9 @@ public static RelCollation reverseCollation(RelCollation original) {
     List<RelFieldCollation> reversedFields = new ArrayList<>();
     for (RelFieldCollation field : original.getFieldCollations()) {
       RelFieldCollation.Direction reversedDirection = field.direction.reverse();
-      
-      RelFieldCollation reversedField = new RelFieldCollation(
-          field.getFieldIndex(),
-          reversedDirection,
-          field.nullDirection
-      );
+
+      RelFieldCollation reversedField =
+          new RelFieldCollation(field.getFieldIndex(), reversedDirection, field.nullDirection);
       reversedFields.add(reversedField);
     }
 

integ-test/src/test/java/org/opensearch/sql/calcite/remote/CalciteExplainIT.java

@@ -206,8 +206,7 @@ public void testFilterFunctionScriptPushDownExplain() throws Exception {
   @Test
   public void testExplainWithReverse() throws IOException {
     String result =
-        executeWithReplace(
-            "explain source=opensearch-sql_test_index_account | reverse | head 5");
+        executeWithReplace("explain source=opensearch-sql_test_index_account | reverse | head 5");
 
     // Verify that the plan contains a LogicalSort with fetch (from head 5)
     assertTrue(result.contains("LogicalSort") && result.contains("fetch=[5]"));
@@ -216,15 +215,15 @@ public void testExplainWithReverse() throws IOException {
     assertTrue(result.contains("ROW_NUMBER()"));
     assertTrue(result.contains("dir0=[DESC]"));
   }
-  
+
   @Test
   public void testExplainWithReversePushdown() throws IOException {
     String query = "source=opensearch-sql_test_index_account | sort - age | reverse";
     var result = explainQueryToString(query);
     String expected = loadFromFile("expectedOutput/calcite/explain_reverse_pushdown_single.json");
     assertJsonEqualsIgnoreId(expected, result);
   }
-  
+
   @Test
   public void testExplainWithReversePushdownMultipleFields() throws IOException {
     String query = "source=opensearch-sql_test_index_account | sort - age, + firstname | reverse";

integ-test/src/test/java/org/opensearch/sql/calcite/remote/CalciteReverseCommandIT.java

@@ -115,7 +115,8 @@ public void testReverseWithMixedSortDirections() throws IOException {
     JSONObject result =
         executeQuery(
             String.format(
-                "source=%s | sort - account_number, + firstname | fields account_number, firstname | reverse",
+                "source=%s | sort - account_number, + firstname | fields account_number, firstname"
+                    + " | reverse",
                 TEST_INDEX_BANK));
     verifySchema(result, schema("account_number", "bigint"), schema("firstname", "string"));
     verifyDataRowsInOrder(
@@ -148,7 +149,8 @@ public void testDoubleReverseWithMixedSortDirections() throws IOException {
     JSONObject result =
         executeQuery(
             String.format(
-                "source=%s | sort - account_number, + firstname | fields account_number, firstname | reverse | reverse",
+                "source=%s | sort - account_number, + firstname | fields account_number, firstname"
+                    + " | reverse | reverse",
                 TEST_INDEX_BANK));
     verifySchema(result, schema("account_number", "bigint"), schema("firstname", "string"));
     verifyDataRowsInOrder(