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)

Reply via email to