[jira] [Created] (FLINK-11009) Add support for FILTER clause for non-windowed aggregation in Table API and SQL

["Dian Fu (JIRA)" <ji...@apache.org>]

Dian Fu created FLINK-11009:
-------------------------------

             Summary: 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


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)