[FLINK-8690] Support distinct aggregation on group windowed streaming tables.

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.6.0
• Component/s: Table SQL / API
• Assignee: Rong Rong
• Reporter: Rong Rong
• Created: 18/Feb/18 16:17
• Updated: 19/Sep/19 19:18
• Resolved: 07/May/18 19:32

Description

Currently, FlinkLogicalAggregate / FlinkLogicalWindowAggregate does not allow distinct aggregate.

We are proposing to reuse distinct aggregate codegen work designed for FlinkLogicalOverAggregate, to support unbounded distinct aggregation on datastream as well.

Issue Links

• links to: GitHub Pull Request #5940