|
5 | 5 |
|
6 | 6 | package org.opensearch.sql.ppl.calcite; |
7 | 7 |
|
8 | | -import java.util.Arrays; |
9 | | -import java.util.List; |
10 | 8 | import org.apache.calcite.rel.RelNode; |
11 | 9 | import org.apache.calcite.test.CalciteAssert; |
12 | 10 | import org.junit.Test; |
@@ -38,35 +36,6 @@ public void testAppendPipe() { |
38 | 36 | verifyPPLToSparkSQL(root, expectedSparkSql); |
39 | 37 | } |
40 | 38 |
|
41 | | - @Test |
42 | | - public void testAppendPipeEmptySearchCommand() { |
43 | | - List<String> emptySourcePPLs = |
44 | | - Arrays.asList( |
45 | | - "source=EMP | append [ | where DEPTNO = 20 ]", |
46 | | - "source=EMP | append [ ]", |
47 | | - "source=EMP | append [ | where DEPTNO = 20 | append [ ] ]", |
48 | | - "source=EMP | append [ | where DEPTNO = 10 | lookup DEPT DEPTNO append LOC as JOB ]"); |
49 | | - |
50 | | - for (String ppl : emptySourcePPLs) { |
51 | | - RelNode root = getRelNode(ppl); |
52 | | - String expectedLogical = |
53 | | - "LogicalUnion(all=[true])\n" |
54 | | - + " LogicalTableScan(table=[[scott, EMP]])\n" |
55 | | - + " LogicalValues(tuples=[[]])\n"; |
56 | | - verifyLogical(root, expectedLogical); |
57 | | - |
58 | | - String expectedSparkSql = |
59 | | - "SELECT *\n" |
60 | | - + "FROM `scott`.`EMP`\n" |
61 | | - + "UNION ALL\n" |
62 | | - + "SELECT *\n" |
63 | | - + "FROM (VALUES (NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL)) `t` (`EMPNO`," |
64 | | - + " `ENAME`, `JOB`, `MGR`, `HIREDATE`, `SAL`, `COMM`, `DEPTNO`)\n" |
65 | | - + "WHERE 1 = 0"; |
66 | | - verifyPPLToSparkSQL(root, expectedSparkSql); |
67 | | - } |
68 | | - } |
69 | | - |
70 | 39 | @Test |
71 | 40 | public void testAppendPipeWithMergedColumns() { |
72 | 41 | String ppl = |
|
0 commit comments