[jira] [Created] (FLINK-24070) Support different over window aggregates in streaming queries

["zl (Jira)" <ji...@apache.org>]

zl created FLINK-24070:
--------------------------

             Summary: Support different over window aggregates in streaming queries
                 Key: FLINK-24070
                 URL: https://issues.apache.org/jira/browse/FLINK-24070
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Planner
            Reporter: zl


Currently, Flink does not support using different over window aggregates in a query statement, such as:

 
{code:java}
// code placeholder
select 
    f1, f2, f3, 
    sum(f3) over (PARTITION BY f1 ORDER BY f2 ROWS BETWEEN 2 PRECEDING AND CURRENT ROW) as sum_1,
    sum(f3) over (PARTITION BY f1 ORDER BY f2 ROWS BETWEEN 5 PRECEDING AND CURRENT ROW) as sum_2
from table_a;{code}
 

However, this feature is commonly used in feature engineering for generating some new features, do we have plan to support this?

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)