flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "yinhua.dai (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-6473) Add OVER window support for batch tables
Date Fri, 23 Mar 2018 09:14:00 GMT

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

yinhua.dai commented on FLINK-6473:
-----------------------------------

[~fhueske]

I can't make it work as retract() only works for the OVER action.

Without OVER, I only know the solution for fixed window, like TUMBLE or HOP window.

If I have below table as source:
||datetime||productId||price||
|3-1|p1|10|
|3-2|p1|20|
|3-3|p1|30|
|3-4|p1|40|

Then I expect the result table would be:
||datetime||productId||average||
|3-1|p1|10/1|
|3-2|p1|(10+20)/2|
|3-3|p1|(10+20+30)/3|
|3-4|p1|(10+20+30+40)/4|

> Add OVER window support for batch tables
> ----------------------------------------
>
>                 Key: FLINK-6473
>                 URL: https://issues.apache.org/jira/browse/FLINK-6473
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table API &amp; SQL
>            Reporter: Fabian Hueske
>            Priority: Major
>
> Add support for OVER windows for batch tables. 
> Since OVER windows are supported for streaming tables, this issue is not about the API
(which is available) but about adding the execution strategies and translation for OVER windows
on batch tables.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message