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)
