[
https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410799#comment-16410799
]
Fabian Hueske edited comment on FLINK-6473 at 3/23/18 7:52 AM:
---------------------------------------------------------------
[~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}
was (Author: yinhua):
[~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.
SELECT productId, AVG(price) OVER(
PARTITION BY productId
ROWS BETWEEN PRECEDING UNBOUNDED AND CURRENT ROW
)
FROM product
> 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 & 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)
