Details
-
New Feature
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
Add support for generating optimized logical plan for Sort and Rank.
There is a summary of Sort and Rank converters:
for batch,
1. Sort without sort fields will be converted to BatchExecLimit
2. Sort with sort fields, null-fetch and null-offset will be converted to BatchExecSort
3. otherwise, Sort will be converted to BatchExecSortLimit
4. RANK function on over with filter will be converted to BatchExecRank
for stream,
1. Sort with time-ascending-order and non-limit will be converted to StreamExecTemporalSort
2. Sort without sort fields will be converted to StreamExecLimit
3. Sort with sort fields, null-fetch and null-offset will be converted to StreamExecSort
4. otherwise, Sort will be converted to StreamExecSortLimit
5. Rank with ROW_NUMBER function which is sorted on proc-time attribute and fetches only one record start from 0 will be converted to StreamExecDeduplicate
5. otherwise, RANK function on over with filter will be converted to StreamExecRank
Attachments
Issue Links
- is a child of
-
FLINK-11488 Add a basic Blink planner framework
-
- Closed
-
- links to
