[
https://issues.apache.org/jira/browse/FLINK-11009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11009:
-----------------------------------
Labels: pull-request-available (was: )
> Add support for FILTER clause for non-windowed aggregation in Table API and
> SQL
> -------------------------------------------------------------------------------
>
> Key: FLINK-11009
> URL: https://issues.apache.org/jira/browse/FLINK-11009
> Project: Flink
> Issue Type: Task
> Components: Table API & SQL
> Reporter: Dian Fu
> Assignee: Dian Fu
> Priority: Major
> Labels: pull-request-available
>
> Currently the following clause is not supported in Flink, the *FILTER* clause
> is ignored in the AggregateCodeGenerator:
> {code:java}
> SELECT
> a, sum(b) filter (where c > 0)
> FROM myTable
> GROUP BY a;{code}
> The aim of this ticket is to add support for *FILTER* clause for non-windowed
> aggregation in both Table API & SQL.
>
> For Table API, it will look like this:
> 'a.count.filter('c > 0)
> myUDAGG('a).filter('c > 0)
> multiParamUDAGG('a, 'b).filter('c > 0)
>
> When working with `distinct`, it will look like this:
> {code:java}
> 'a.count.distinct.filter('c > 0) or 'a.count.filter('c > 0).distinct
> myUDAGG('a).distinct.filter('c > 0) or myUDAGG('a).filter('c > 0).distinct
> multiParamUDAGG('a, 'b).distinct.filter('c > 0) or multiParamUDAGG('a,
> 'b).filter('c > 0).distinct{code}
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
