[FLINK-8689] Add runtime support of distinct filter using MapView

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.6.0
• Assignee: Rong Rong
• Reporter: Rong Rong
• Created: 18/Feb/18 16:16
• Updated: 19/Sep/19 19:15
• Resolved: 26/Apr/18 21:23

Description

This ticket should cover distinct aggregate function support to codegen for AggregateCall, where isDistinct fields is set to true.

This can be verified using the following SQL, which is not currently producing correct results.

SELECT
  a,
  SUM(b) OVER (PARTITION BY a ORDER BY proctime ROWS BETWEEN 5 PRECEDING AND CURRENT ROW)
FROM
  MyTable

 

 

Issue Links

• links to: GitHub Pull Request #5555