Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
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
Attachments
Issue Links
- duplicates
-
FLINK-11943 Support TopN feature for SQL
-
- Closed
-
-
-
- Closed
-
- is a child of
-
FLINK-11489 Add an initial Blink SQL streaming runtime
-
- Closed
-
- links to
