[ https://issues.apache.org/jira/browse/FLINK-12017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu closed FLINK-12017. --------------------------- > Introduce Rank and Deduplicate operators for blink streaming runtime > ---------------------------------------------------------------------- > > Key: FLINK-12017 > URL: https://issues.apache.org/jira/browse/FLINK-12017 > Project: Flink > Issue Type: Task > Components: Table SQL / Planner > Reporter: Jing Zhang > Assignee: Jing Zhang > Priority: Major > Labels: pull-request-available > Time Spent: 10m > Remaining Estimate: 0h > > Support translation from Rank/Deduplicate to StreamTransformation, So > following sql can be run: > 1. > SELECT a, b, c > FROM ( > SELECT *, > ROW_NUMBER() OVER (PARTITION BY b ORDER BY proc DESC) as rowNum > FROM T > ) > WHERE rowNum = 1 > 2. > SELECT * > FROM ( > SELECT category, shopId, num, > ROW_NUMBER() OVER (PARTITION BY category ORDER BY num DESC) as rank_num > FROM T) > WHERE rank_num <= 2 > -- This message was sent by Atlassian JIRA (v7.6.3#76005)