feat(window): initial impl window function

[ariesdevil]

I hereby agree to the terms of the CLA available at: https://databend.rs/dev/policies/cla/

Summary

initial impl window function

Closes #issue

[vercel]

The latest updates on your projects. Learn more about Vercel for Git ↗︎

1 Ignored Deployment

Name	Status	Preview	Comments	Updated
databend	⬜️ Ignored (Inspect)			Mar 28, 2023 at 9:41AM (UTC)

[ariesdevil]

explain plan

mysql> explain select a, sum(b) over(partition by c order by a rows between 3 preceding and 3 following) as s from t;
+------------------------------------------------------------------------------------------------------------------------------+
| explain                                                                                                                      |
+------------------------------------------------------------------------------------------------------------------------------+
| EvalScalar                                                                                                                   |
| ├── expressions: [sum_with_window (#3)]                                                                                      |
| ├── estimated rows: 6.00                                                                                                     |
| └── Window                                                                                                                   |
|     ├── aggregate function: [sum(b)]                                                                                         |
|     ├── partition by: [c]                                                                                                    |
|     ├── order by: [a]                                                                                                        |
|     └── TableScan                                                                                                            |
|         ├── table: default.default.t                                                                                         |
|         ├── read rows: 6                                                                                                     |
|         ├── read bytes: 55                                                                                                   |
|         ├── partitions total: 1                                                                                              |
|         ├── partitions scanned: 1                                                                                            |
|         ├── pruning stats: [segments: <range pruning: 1 to 1>, blocks: <range pruning: 1 to 1, bloom pruning: 0 to 0>]       |
|         ├── push downs: [filters: [], limit: NONE]                                                                           |
|         ├── output columns: [a]                                                                                              |
|         └── estimated rows: 6.00                                                                                             |
+------------------------------------------------------------------------------------------------------------------------------+

explain pipeline

mysql> explain pipeline select a, sum(b) over(partition by c order by a rows between 3 preceding and 3 following) as s from t;
+---------------------------------------------------------------------------------------------+
| explain                                                                                     |
+---------------------------------------------------------------------------------------------+
| CompoundBlockOperator(Project) × 1 processor                                                |
|   CompoundBlockOperator(Map) × 1 processor                                                  |
|     Transform Window × 1 processor                                                          |
|       Merge (SortMergeTransform × 16 processors) to (Transform Window × 1)                  |
|         SortMergeTransform × 16 processors                                                  |
|           SortPartialTransform × 16 processors                                              |
|             Merge (DeserializeDataTransform × 1 processor) to (SortPartialTransform × 16)   |
|               DeserializeDataTransform × 1 processor                                        |
|                 SyncReadParquetDataSource × 1 processor                                     |
+---------------------------------------------------------------------------------------------+
9 rows in set (0.02 sec)
Read 0 rows, 0.00 B in 0.004 sec., 0 rows/sec., 0.00 B/sec.

[ariesdevil]

FYI: the failed 13_0008_q8.sql in test-stateless-cluster can run successfully on release mode.
related: #10585