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

Jingsong Lee commented on FLINK-24070:
--------------------------------------

Is it because f2 is not a time field?

> 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
>            Priority: Major
>
> 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