[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15892596#comment-15892596
]
ASF GitHub Bot commented on FLINK-5654:
---------------------------------------
GitHub user huawei-flink opened a pull request:
https://github.com/apache/flink/pull/3459
[FLINK-5654] Add processing time OVER RANGE BETWEEN x PRECEDING aggregation
to SQL
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the items into account, feel free to open your
pull request. For more information and/or questions please refer to the [How To
Contribute guide](http://flink.apache.org/how-to-contribute.html).
In addition to going through the list, please provide a meaningful
description of your changes.
- [ X] General
- The pull request references the related JIRA issue ("[FLINK-XXX] Jira
title text")
- The pull request addresses only one issue
- Each commit in the PR has a meaningful commit message (including the
JIRA id)
- [X ] Documentation
- Documentation has been added for new functionality
- Old documentation affected by the pull request has been updated
- JavaDoc for public methods has been added
- [x ] Tests & Build
- Functionality added by the pull request is covered by tests
- `mvn clean verify` has been executed successfully locally or a Travis
build has passed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/huawei-flink/flink FLINK-5654
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3459.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3459
----
commit 72ec35a7380a4d73bd092ce14962ab2248139bae
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-01T16:15:58Z
First implementation of ProcTime()
commit e98c28616af1cf67d3ad3277d9cc2ca335604eca
Author: rtudoran <rtudoran@bigdata-hp3>
Date: 2017-02-02T10:30:40Z
Disambiguate for the OVER BY clause, which should not be treated as a
RexOver expression in Logical Project
commit b7e6a673b88b6181c06071cd6c7bda55c25a62b4
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-02T12:07:11Z
Added return to disambiguation method for rexover
commit cda17565d5969f29b16923b631178a2cbf64791b
Author: rtudoran <rtudoran@bigdata-hp3>
Date: 2017-02-02T16:00:20Z
Enable the LogicalWindow operators in query translation
commit 4b3e54281018b83c818f91e09a5321c34bbf297b
Author: rtudoran <rtudoran@bigdata-hp3>
Date: 2017-02-03T14:59:39Z
Added a DataStreamRel version that can be extended in java
commit cc960d699db369cc8dc4e155cc5c5f6c3baf74a4
Author: rtudoran <rtudoran@bigdata-hp3>
Date: 2017-02-03T15:35:18Z
Add skeleton for the implementation of the aggregates over sliding
window with processing time and time boundaries
commit 2390a9d3dc15afba01185c47f61a9ea830ea5acc
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-06T10:33:57Z
committing changes with stub modifications before chekout proctime
branch
commit eaf4e92784dab01b17004390968ca4b1fe7c4bea
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-06T13:17:43Z
ignore aggregation test and implemented simple proctime test
commit 16ccd7f5bf019803ea8b53f09a126ec53a5a6d59
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-06T14:17:03Z
Merge branch 'FLINK-5710' of https://github.com/huawei-flink/flink into
FLINK-5653
commit 10f7bc5e2086e41ec76cbabdcd069c71a491671a
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-07T09:42:41Z
committing first key selector and utils
commit 31060e46f78729880c03e8cab0f92ff06faec4f0
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-07T11:16:43Z
Changed ProcTime from time to timestamp
commit 69289bad836a5fdace271b28a15ca0e309e50b17
Author: rtudoran <[email protected]>
Date: 2017-02-07T13:13:23Z
Merge branch 'FLINK-5710' of https://github.com/huawei-flink/flink into
FLINK-5654
commit 3392817045ed166df5f55d22fde34cbd98c775db
Author: rtudoran <[email protected]>
Date: 2017-02-07T13:14:50Z
Merge branch 'FLINK-5653' of https://github.com/huawei-flink/flink into
FLINK-5654
commit d2ea0076b5e3561585c4eaea84025e50beaacf9a
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-07T09:42:41Z
fixing linelength and other issues
commit f29f564bb7fe7496b9f3d2f45a6b4469af559378
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-07T13:46:30Z
Merge branch 'FLINK-5653' of https://github.com/huawei-flink/flink.git
into FLINK-5653
Conflicts:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/logical/rel/DataStreamWindowRowAggregate.java
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/logical/rel/util/StreamGroupKeySelector.java
commit ea145ecefc2be1bea71e995dbf39585e7fa44012
Author: rtudoran <[email protected]>
Date: 2017-02-07T13:46:53Z
Merge branch 'FLINK-5653' of https://github.com/huawei-flink/flink into
FLINK-5654
commit 30749fc34d96a00427d079f803d44ba7007e619b
Author: rtudoran <[email protected]>
Date: 2017-02-08T17:52:18Z
Added the integration of the WindowProcTime object in the convertion
rules and enable the convertion
commit b001ce5505833773a9143ff1f8581eb308357b6d
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-09T14:06:48Z
pushing Util function to synchronize with other branch
commit 41c9ed49359b2ae9ad552eb07e51c8a60c219e97
Author: rtudoran <[email protected]>
Date: 2017-02-09T14:07:35Z
Merge branch 'FLINK-5653' of https://github.com/huawei-flink/flink into
FLINK-5654
commit 9c0dc0b17824ec967635c93974004533db3118b9
Author: rtudoran <[email protected]>
Date: 2017-02-09T16:57:49Z
partition verification
commit cb3d7050fff0e119c1e49b7b2ad5294774041091
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-10T14:48:03Z
First version of ProcTime aggregation with Max, Min and Sum. To be
tested in a deeper way, as well as introducing other aggregations
commit 92d96bfe7e4dfe6426e10e59237fbae3cf772b61
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-10T15:00:22Z
Merge branch 'FLINK-5654' of https://github.com/huawei-flink/flink into
FLINK-5653
# Conflicts:
#
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/logical/rel/util/WindowAggregateUtil.java
commit 4e8ad831a04347bb94fae23cbc576f23e81fca9d
Author: rtudoran <[email protected]>
Date: 2017-02-10T16:21:56Z
small progress for global window
commit 6079d9ede35ffa6297130a08764fcb69d2609fbd
Author: rtudoran <[email protected]>
Date: 2017-02-10T16:28:31Z
Merg conflict solved
commit 9ec8edf17988b5d2ac2e5fa428854ef9c99be1e4
Author: rtudoran <[email protected]>
Date: 2017-02-10T16:37:04Z
Build errors solved
commit 2d6ea54cdfe7096fcd6bbb8ae8bbdf2cd2ba2d0c
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-10T16:53:03Z
fixing unused imports
commit da4992a7dccc1f7022c9adaca9adf70c56d36f8f
Author: rtudoran <[email protected]>
Date: 2017-02-28T09:42:08Z
Merge branch 'FLINK-5653' of https://github.com/huawei-flink/flink into
FLINK-5654
commit 40f5ff80bb3023ce1125094dca135bc230ab67ba
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-28T15:52:35Z
Adding aggregation functions in new package
commit 6b5aa7cc40e72a3bbd67b235fc6c2f75f2e6804b
Author: rtudoran <[email protected]>
Date: 2017-02-28T15:53:14Z
Merge branch 'FLINK-5653' of https://github.com/huawei-flink/flink into
FLINK-5654
commit 65f47e99f3770a4980a3ddc412a6904ca5c69c55
Author: Stefano Bortoli <[email protected]>
Date: 2017-02-28T15:59:08Z
pushing first version of windowed aggregation working on keyed stream
----
> Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL
> ---------------------------------------------------------------------
>
> Key: FLINK-5654
> URL: https://issues.apache.org/jira/browse/FLINK-5654
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Reporter: Fabian Hueske
> Assignee: radu
>
> The goal of this issue is to add support for OVER RANGE 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() RANGE BETWEEN INTERVAL '1'
> HOUR PRECEDING AND CURRENT ROW) AS sumB,
> MIN(b) OVER (PARTITION BY c ORDER BY procTime() RANGE BETWEEN INTERVAL '1'
> HOUR 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.
> - UNBOUNDED PRECEDING is not supported (see FLINK-5657)
> - 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.15#6346)
