[jira] [Created] (FLINK-12018) Add support for generating optimized logical plan for Sort and Rank

[Shang Yuanchun (Jira)]

godfrey he created FLINK-12018:
----------------------------------

             Summary: Add support for generating optimized logical plan for Sort and Rank
                 Key: FLINK-12018
                 URL: https://issues.apache.org/jira/browse/FLINK-12018
             Project: Flink
          Issue Type: New Feature
            Reporter: godfrey he
            Assignee: godfrey he


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, fetch and offset 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 with limit will be converted to StreamExecRank
3. Sort which is sorted on proc-time attribute and fetches only one record start from 0 will be converted to StreamExecFirstLastRow
4. otherwise, Sort will be converted to StreamExecSort
5.  RANK function on over with filter will be converted to StreamExecRank
6. Rank with ROW_NUMBER function which is sorted on proc-time attribute and fetches only one record start from 0 will be converted to StreamExecFirstLastRow



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)