Hi all, I was thinking to open a JIRA for the procTime() function so that it could be merged before and others could use it as well. What do you think?
Regards, Stefano -----Original Message----- From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Friday, January 27, 2017 10:34 AM To: dev@flink.apache.org Subject: Re: [jira] [Created] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL Hi Stefano, I can assign the issue to you if you want to. Just drop a comment in JIRA. Best, Fabian 2017-01-27 9:39 GMT+01:00 Stefano Bortoli <stefano.bort...@huawei.com>: > Hi Fabian, > > In the next days I will start working on this issue. As soon as I have > a proposal I will start sharing it for discussion. > > Regards, > Dr. Stefano Bortoli > Senior Research Engineer - Big Data and Semantic Technology Expert IT > R&D Division > > -----Original Message----- > From: Fabian Hueske (JIRA) [mailto:j...@apache.org] > Sent: Thursday, January 26, 2017 2:49 PM > To: dev@flink.apache.org > Subject: [jira] [Created] (FLINK-5656) Add processing time OVER ROWS > BETWEEN UNBOUNDED PRECEDING aggregation to SQL > > Fabian Hueske created FLINK-5656: > ------------------------------------ > > Summary: Add processing time OVER ROWS BETWEEN UNBOUNDED > PRECEDING aggregation to SQL > Key: FLINK-5656 > URL: https://issues.apache.org/jira/browse/FLINK-5656 > Project: Flink > Issue Type: Sub-task > Components: Table API & SQL > Reporter: Fabian Hueske > > > The goal of this issue is to add support for OVER ROW aggregations on > processing time streams to the SQL interface. > > Queries similar to the following should be supported: > {code} > SELECT > a, > SUM(b) OVER (PARTITION BY c ORDER BY procTime() ROW BETWEEN > UNBOUNDED PRECEDING AND CURRENT ROW) AS sumB, > MIN(b) OVER (PARTITION BY c ORDER BY procTime() ROW BETWEEN > UNBOUNDED PRECEDING AND CURRENT ROW) AS minB FROM myStream {code} > > The following restrictions should initially apply: > - All OVER clauses in the same SELECT clause must be exactly the same. > - The PARTITION BY clause is optional (no partitioning results in > single threaded execution). > - The ORDER BY clause may only have procTime() as parameter. > procTime() is a parameterless scalar function that just indicates processing > time mode. > - x PRECEDING is not supported (see FLINK-5653) > - FOLLOWING is not supported. > > The restrictions will be resolved in follow up issues. If we find that > some of the restrictions are trivial to address, we can add the > functionality in this issue as well. > > This issue includes: > - Design of the DataStream operator to compute OVER ROW aggregates > - Translation from Calcite's RelNode representation (LogicalProject > with RexOver expression). > > > > > -- > This message was sent by Atlassian JIRA > (v6.3.4#6332) >
