flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Zhenghua Gao (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries
Date Mon, 16 Jan 2017 01:51:26 GMT

    [ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823352#comment-15823352

Zhenghua Gao commented on FLINK-3475:

I have created a pr for this issue: https://github.com/apache/flink/pull/3111.
Currently, calcite's AggregateExpandDistinctAggregatesRule can help flink to support distinct
aggregate SQL.
After do some tests, i find some bad cases which described in https://issues.apache.org/jira/browse/CALCITE-1558.
So I copied the calcite class to flink project and did a quick fix.

> DISTINCT aggregate function support for SQL queries
> ---------------------------------------------------
>                 Key: FLINK-3475
>                 URL: https://issues.apache.org/jira/browse/FLINK-3475
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table API & SQL
>            Reporter: Chengxiang Li
>            Assignee: Zhenghua Gao
> DISTINCT aggregate function may be able to reuse the aggregate function instead of separate
implementation, and let Flink runtime take care of duplicate records.

This message was sent by Atlassian JIRA

View raw message