You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/07/24 12:01:00 UTC

[jira] [Issue Comment Deleted] (FLINK-6473) Add OVER window support for batch tables

     [ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Fabian Hueske updated FLINK-6473:
---------------------------------
    Comment: was deleted

(was: [~fhueske]

Wondering before this feature is implemented, how could I implement aggregation function for incremental window?

For example, I want to calculate an average of price from the beginning to today for each day for a batch table.

{code}
SELECT productId, AVG(price) OVER(
    PARTITION BY productId
    ROWS BETWEEN PRECEDING UNBOUNDED AND CURRENT ROW
    )
FROM product
{code})

> 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)