[FLINK-5315] Support distinct aggregations in table api

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.7.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Rong Rong
• Reporter: Kurt Young
• Created: 12/Dec/16 05:43
• Updated: 19/Sep/19 19:18
• Resolved: 13/Sep/18 21:26

Description

Support distinct aggregations in Table API in the following format:

For Expressions:

'a.count.distinct // Expressions distinct modifier

For User-defined Function:

singleArgUdaggFunc.distinct('a) // FunctionCall distinct modifier
multiArgUdaggFunc.distinct('a, 'b) // FunctionCall distinct modifier

Issue Links

• is related to: FLINK-8688 Enable distinct aggregation for data stream on Table/SQL API
• requires: FLINK-3475 DISTINCT aggregate function support for SQL queries
• links to: GitHub Pull Request #6521