Fix PPL unit test assertions to match updated plan output

Author: yuancu

ppl/src/test/java/org/opensearch/sql/ppl/calcite/CalcitePPLStreamstatsTest.java

@@ -33,8 +33,8 @@ public void testStreamstatsBy() {
 
     String expectedSparkSql =
         "SELECT `EMPNO`, `ENAME`, `JOB`, `MGR`, `HIREDATE`, `SAL`, `COMM`, `DEPTNO`, MAX(`SAL`)"
-            + " OVER (PARTITION BY `DEPTNO` ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)"
-            + " `max(SAL)`\n"
+            + " OVER (PARTITION BY `DEPTNO` ROWS BETWEEN UNBOUNDED"
+            + " PRECEDING AND CURRENT ROW) `max(SAL)`\n"
             + "FROM (SELECT `EMPNO`, `ENAME`, `JOB`, `MGR`, `HIREDATE`, `SAL`, `COMM`, `DEPTNO`,"
             + " ROW_NUMBER() OVER () `__stream_seq__`\n"
             + "FROM `scott`.`EMP`) `t`\n"
@@ -52,8 +52,8 @@ public void testStreamstatsByNullBucket() {
             + "  LogicalSort(sort0=[$8], dir0=[ASC])\n"
             + "    LogicalProject(EMPNO=[$0], ENAME=[$1], JOB=[$2], MGR=[$3], HIREDATE=[$4],"
             + " SAL=[$5], COMM=[$6], DEPTNO=[$7], __stream_seq__=[$8], max(SAL)=[CASE(IS NOT"
-            + " NULL($7), MAX($5) OVER (PARTITION BY $7 ROWS UNBOUNDED PRECEDING), null:DECIMAL(7,"
-            + " 2))])\n"
+            + " NULL($7), MAX($5) OVER (PARTITION BY $7 ROWS UNBOUNDED"
+            + " PRECEDING), null:DECIMAL(7, 2))])\n"
             + "      LogicalProject(EMPNO=[$0], ENAME=[$1], JOB=[$2], MGR=[$3], HIREDATE=[$4],"
             + " SAL=[$5], COMM=[$6], DEPTNO=[$7], __stream_seq__=[ROW_NUMBER() OVER ()])\n"
             + "        LogicalTableScan(table=[[scott, EMP]])\n";
@@ -76,14 +76,15 @@ public void testStreamstatsCurrent() {
     RelNode root = getRelNode(ppl);
     String expectedLogical =
         "LogicalProject(EMPNO=[$0], ENAME=[$1], JOB=[$2], MGR=[$3], HIREDATE=[$4], SAL=[$5],"
-            + " COMM=[$6], DEPTNO=[$7], max(SAL)=[MAX($5) OVER (ROWS BETWEEN UNBOUNDED PRECEDING"
-            + " AND 1 PRECEDING)])\n"
+            + " COMM=[$6], DEPTNO=[$7], max(SAL)=[MAX($5) OVER (ROWS BETWEEN"
+            + " UNBOUNDED PRECEDING AND 1 PRECEDING)])\n"
             + "  LogicalTableScan(table=[[scott, EMP]])\n";
     verifyLogical(root, expectedLogical);
 
     String expectedSparkSql =
         "SELECT `EMPNO`, `ENAME`, `JOB`, `MGR`, `HIREDATE`, `SAL`, `COMM`, `DEPTNO`, MAX(`SAL`)"
-            + " OVER (ROWS BETWEEN UNBOUNDED PRECEDING AND 1 PRECEDING) `max(SAL)`\n"
+            + " OVER (ROWS BETWEEN UNBOUNDED PRECEDING AND 1 PRECEDING)"
+            + " `max(SAL)`\n"
             + "FROM `scott`.`EMP`";
     verifyPPLToSparkSQL(root, expectedSparkSql);
   }
@@ -147,7 +148,8 @@ public void testStreamstatsGlobal() {
 
     String expectedSparkSql =
         "SELECT `EMPNO`, `ENAME`, `JOB`, `MGR`, `HIREDATE`, `SAL`, `COMM`, `DEPTNO`, MAX(`SAL`)"
-            + " OVER (PARTITION BY `DEPTNO` ROWS BETWEEN 4 PRECEDING AND CURRENT ROW) `max(SAL)`\n"
+            + " OVER (PARTITION BY `DEPTNO` ROWS BETWEEN 4 PRECEDING"
+            + " AND CURRENT ROW) `max(SAL)`\n"
             + "FROM (SELECT `EMPNO`, `ENAME`, `JOB`, `MGR`, `HIREDATE`, `SAL`, `COMM`, `DEPTNO`,"
             + " ROW_NUMBER() OVER () `__stream_seq__`\n"
             + "FROM `scott`.`EMP`) `t`\n"

ppl/src/test/java/org/opensearch/sql/ppl/calcite/CalcitePPLTransposeTest.java

@@ -105,8 +105,8 @@ public void testMultipleAggregatesWithAliasesTranspose() {
             + " `t1`.`_row_number_transpose_`, `t2`.`column`, CASE WHEN `t2`.`column` = 'avg_sal'"
             + " THEN NUMBER_TO_STRING(`t1`.`avg_sal`) WHEN `t2`.`column` = 'max_sal' THEN"
             + " NUMBER_TO_STRING(`t1`.`max_sal`) WHEN `t2`.`column` = 'min_sal' THEN"
-            + " NUMBER_TO_STRING(`t1`.`min_sal`) WHEN `t2`.`column` = 'cnt' THEN CAST(`t1`.`cnt` AS"
-            + " STRING) ELSE NULL END `value`\n"
+            + " NUMBER_TO_STRING(`t1`.`min_sal`) WHEN `t2`.`column` = 'cnt' THEN"
+            + " CAST(`t1`.`cnt` AS STRING) ELSE NULL END `value`\n"
             + "FROM (SELECT AVG(`SAL`) `avg_sal`, MAX(`SAL`) `max_sal`, MIN(`SAL`) `min_sal`,"
             + " COUNT(*) `cnt`, ROW_NUMBER() OVER () `_row_number_transpose_`\n"
             + "FROM `scott`.`EMP`) `t1`\n"
@@ -238,9 +238,9 @@ public void testTransposeWithLimitColumnName() {
             + "FROM (SELECT `t`.`ENAME`, `t`.`COMM`, `t`.`JOB`, `t`.`SAL`,"
             + " `t`.`_row_number_transpose_`, `t0`.`column_names`, CASE WHEN `t0`.`column_names` ="
             + " 'ENAME' THEN CAST(`t`.`ENAME` AS STRING) WHEN `t0`.`column_names` = 'COMM' THEN"
-            + " NUMBER_TO_STRING(`t`.`COMM`) WHEN `t0`.`column_names` = 'JOB' THEN CAST(`t`.`JOB`"
-            + " AS STRING) WHEN `t0`.`column_names` = 'SAL' THEN NUMBER_TO_STRING(`t`.`SAL`) ELSE"
-            + " NULL END `value`\n"
+            + " NUMBER_TO_STRING(`t`.`COMM`) WHEN `t0`.`column_names` = 'JOB' THEN"
+            + " CAST(`t`.`JOB` AS STRING) WHEN `t0`.`column_names` = 'SAL' THEN"
+            + " NUMBER_TO_STRING(`t`.`SAL`) ELSE NULL END `value`\n"
             + "FROM (SELECT `ENAME`, `COMM`, `JOB`, `SAL`, ROW_NUMBER() OVER ()"
             + " `_row_number_transpose_`\n"
             + "FROM `scott`.`EMP`) `t`\n"