[SPARK-29108][SQL][TESTS][FOLLOWUP] Comment out no use test case and add 'insert into' statement of window.sql (Part 2)

### What changes were proposed in this pull request?
When I running the `window_part2.sql` tests find it lack insert sql. Therefore, the output is empty.
I checked the postgresql and reference https://github.com/postgres/postgres/blob/master/src/test/regress/sql/window.sql
Although `window_part1.sql` and `window_part3.sql` exists the insert sql, I think should also add it into `window_part2.sql`.
Because only one case reference the table `empsalary` and it throws `AnalysisException`.
```
-- !query
select last(salary) over(order by salary range between 1000 preceding and 1000 following),
lag(salary) over(order by salary range between 1000 preceding and 1000 following),
salary from empsalary
-- !query schema
struct<>
-- !query output
org.apache.spark.sql.AnalysisException
Window Frame specifiedwindowframe(RangeFrame, -1000, 1000) must match the required frame specifiedwindowframe(RowFrame, -1, -1);
```

So we should do four work:
1. comment out the only one case and create a new ticket.
2. Add `INSERT INTO empsalary`.

Note: window_part4.sql not use the table `empsalary`.

### Why are the changes needed?
Supplementary test data.

### Does this PR introduce any user-facing change?
No

### How was this patch tested?
New test case

Closes #27439 from beliefer/add-insert-to-window.

Authored-by: beliefer <beliefer@163.com>
Signed-off-by: HyukjinKwon <gurwls223@apache.org>
This commit is contained in:
beliefer 2020-02-06 15:24:26 +09:00 committed by HyukjinKwon
parent c27a616450
commit c8ef1dee90
2 changed files with 34 additions and 14 deletions

View file

@ -15,6 +15,18 @@ CREATE TABLE empsalary (
enroll_date date enroll_date date
) USING parquet; ) USING parquet;
INSERT INTO empsalary VALUES
('develop', 10, 5200, date '2007-08-01'),
('sales', 1, 5000, date '2006-10-01'),
('personnel', 5, 3500, date '2007-12-10'),
('sales', 4, 4800, date '2007-08-08'),
('personnel', 2, 3900, date '2006-12-23'),
('develop', 7, 4200, date '2008-01-01'),
('develop', 9, 4500, date '2008-01-01'),
('sales', 3, 4800, date '2007-08-01'),
('develop', 8, 6000, date '2006-10-01'),
('develop', 11, 5200, date '2007-08-15');
-- [SPARK-28429] SQL Datetime util function being casted to double instead of timestamp -- [SPARK-28429] SQL Datetime util function being casted to double instead of timestamp
-- CREATE TEMP VIEW v_window AS -- CREATE TEMP VIEW v_window AS
-- SELECT i, min(i) over (order by i range between '1 day' preceding and '10 days' following) as min_i -- SELECT i, min(i) over (order by i range between '1 day' preceding and '10 days' following) as min_i
@ -99,9 +111,10 @@ FROM tenk1 WHERE unique1 < 10;
-- nth_value(salary, 1) over(order by salary range between 1000 preceding and 1000 following), -- nth_value(salary, 1) over(order by salary range between 1000 preceding and 1000 following),
-- salary from empsalary; -- salary from empsalary;
select last(salary) over(order by salary range between 1000 preceding and 1000 following), -- [SPARK-30734] AnalysisException that window RangeFrame not match RowFrame
lag(salary) over(order by salary range between 1000 preceding and 1000 following), -- select last(salary) over(order by salary range between 1000 preceding and 1000 following),
salary from empsalary; -- lag(salary) over(order by salary range between 1000 preceding and 1000 following),
-- salary from empsalary;
-- [SPARK-27951] ANSI SQL: NTH_VALUE function -- [SPARK-27951] ANSI SQL: NTH_VALUE function
-- select first_value(salary) over(order by salary range between 1000 following and 3000 following -- select first_value(salary) over(order by salary range between 1000 following and 3000 following

View file

@ -15,6 +15,24 @@ struct<>
-- !query
INSERT INTO empsalary VALUES
('develop', 10, 5200, date '2007-08-01'),
('sales', 1, 5000, date '2006-10-01'),
('personnel', 5, 3500, date '2007-12-10'),
('sales', 4, 4800, date '2007-08-08'),
('personnel', 2, 3900, date '2006-12-23'),
('develop', 7, 4200, date '2008-01-01'),
('develop', 9, 4500, date '2008-01-01'),
('sales', 3, 4800, date '2007-08-01'),
('develop', 8, 6000, date '2006-10-01'),
('develop', 11, 5200, date '2007-08-15')
-- !query schema
struct<>
-- !query output
-- !query -- !query
SELECT sum(unique1) over (order by four range between 2 preceding and 1 preceding), SELECT sum(unique1) over (order by four range between 2 preceding and 1 preceding),
unique1, four unique1, four
@ -72,17 +90,6 @@ struct<sum(unique1) OVER (PARTITION BY four ORDER BY unique1 ASC NULLS FIRST RAN
8 6 2 8 6 2
-- !query
select last(salary) over(order by salary range between 1000 preceding and 1000 following),
lag(salary) over(order by salary range between 1000 preceding and 1000 following),
salary from empsalary
-- !query schema
struct<>
-- !query output
org.apache.spark.sql.AnalysisException
Window Frame specifiedwindowframe(RangeFrame, -1000, 1000) must match the required frame specifiedwindowframe(RowFrame, -1, -1);
-- !query -- !query
select ss.id, ss.y, select ss.id, ss.y,
first(ss.y) over w, first(ss.y) over w,