@@ -1001,8 +1001,8 @@ public void testJoinWithFieldListMaxGreaterThanZero() {
10011001 + " LogicalTableScan(table=[[scott, EMP]])\n "
10021002 + " LogicalProject(DEPTNO=[$0], DNAME=[$1], LOC=[$2])\n "
10031003 + " LogicalFilter(condition=[<=($3, 1)])\n "
1004- + " LogicalProject(DEPTNO=[$0], DNAME=[$1], LOC=[$2], _row_number_=[ROW_NUMBER() "
1005- + " OVER (PARTITION BY $0 ORDER BY $0)])\n "
1004+ + " LogicalProject(DEPTNO=[$0], DNAME=[$1], LOC=[$2],"
1005+ + " _row_number_dedup_=[ROW_NUMBER() OVER (PARTITION BY $0 ORDER BY $0)])\n "
10061006 + " LogicalTableScan(table=[[scott, DEPT]])\n " ;
10071007 verifyLogical (root , expectedLogical );
10081008 verifyResultCount (root , 14 );
@@ -1013,9 +1013,9 @@ public void testJoinWithFieldListMaxGreaterThanZero() {
10131013 + "FROM `scott`.`EMP`\n "
10141014 + "LEFT JOIN (SELECT `DEPTNO`, `DNAME`, `LOC`\n "
10151015 + "FROM (SELECT `DEPTNO`, `DNAME`, `LOC`, ROW_NUMBER() OVER (PARTITION BY `DEPTNO`"
1016- + " ORDER BY `DEPTNO` NULLS LAST) `_row_number_ `\n "
1016+ + " ORDER BY `DEPTNO` NULLS LAST) `_row_number_dedup_ `\n "
10171017 + "FROM `scott`.`DEPT`) `t`\n "
1018- + "WHERE `_row_number_ ` <= 1) `t1` ON `EMP`.`DEPTNO` = `t1`.`DEPTNO`" ;
1018+ + "WHERE `_row_number_dedup_ ` <= 1) `t1` ON `EMP`.`DEPTNO` = `t1`.`DEPTNO`" ;
10191019 verifyPPLToSparkSQL (root , expectedSparkSql );
10201020 }
10211021
@@ -1030,8 +1030,8 @@ public void testJoinWithCriteriaMaxGreaterThanZero() {
10301030 + " LogicalTableScan(table=[[scott, EMP]])\n "
10311031 + " LogicalProject(DEPTNO=[$0], DNAME=[$1], LOC=[$2])\n "
10321032 + " LogicalFilter(condition=[<=($3, 1)])\n "
1033- + " LogicalProject(DEPTNO=[$0], DNAME=[$1], LOC=[$2], _row_number_=[ROW_NUMBER() "
1034- + " OVER (PARTITION BY $0 ORDER BY $0)])\n "
1033+ + " LogicalProject(DEPTNO=[$0], DNAME=[$1], LOC=[$2],"
1034+ + " _row_number_dedup_=[ROW_NUMBER() OVER (PARTITION BY $0 ORDER BY $0)])\n "
10351035 + " LogicalTableScan(table=[[scott, DEPT]])\n " ;
10361036 verifyLogical (root , expectedLogical );
10371037 verifyResultCount (root , 14 );
@@ -1043,9 +1043,9 @@ public void testJoinWithCriteriaMaxGreaterThanZero() {
10431043 + "FROM `scott`.`EMP`\n "
10441044 + "LEFT JOIN (SELECT `DEPTNO`, `DNAME`, `LOC`\n "
10451045 + "FROM (SELECT `DEPTNO`, `DNAME`, `LOC`, ROW_NUMBER() OVER (PARTITION BY `DEPTNO`"
1046- + " ORDER BY `DEPTNO` NULLS LAST) `_row_number_ `\n "
1046+ + " ORDER BY `DEPTNO` NULLS LAST) `_row_number_dedup_ `\n "
10471047 + "FROM `scott`.`DEPT`) `t`\n "
1048- + "WHERE `_row_number_ ` <= 1) `t1` ON `EMP`.`DEPTNO` = `t1`.`DEPTNO`" ;
1048+ + "WHERE `_row_number_dedup_ ` <= 1) `t1` ON `EMP`.`DEPTNO` = `t1`.`DEPTNO`" ;
10491049 verifyPPLToSparkSQL (root , expectedSparkSql );
10501050 }
10511051
0 commit comments