flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL
Date Thu, 02 Mar 2017 16:53:45 GMT

    [ 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:


    [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
    - [ 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:


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 <s.bortoli@gmail.com>
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 <s.bortoli@gmail.com>
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 <s.bortoli@gmail.com>
Date:   2017-02-06T10:33:57Z

    committing changes with stub modifications before chekout proctime

commit eaf4e92784dab01b17004390968ca4b1fe7c4bea
Author: Stefano Bortoli <s.bortoli@gmail.com>
Date:   2017-02-06T13:17:43Z

    ignore aggregation test and implemented simple proctime test

commit 16ccd7f5bf019803ea8b53f09a126ec53a5a6d59
Author: Stefano Bortoli <s.bortoli@gmail.com>
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 <s.bortoli@gmail.com>
Date:   2017-02-07T09:42:41Z

    committing first key selector and utils

commit 31060e46f78729880c03e8cab0f92ff06faec4f0
Author: Stefano Bortoli <s.bortoli@gmail.com>
Date:   2017-02-07T11:16:43Z

    Changed ProcTime from time to timestamp

commit 69289bad836a5fdace271b28a15ca0e309e50b17
Author: rtudoran <tudoranradu@ymail.com>
Date:   2017-02-07T13:13:23Z

    Merge branch 'FLINK-5710' of https://github.com/huawei-flink/flink into FLINK-5654

commit 3392817045ed166df5f55d22fde34cbd98c775db
Author: rtudoran <tudoranradu@ymail.com>
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 <s.bortoli@gmail.com>
Date:   2017-02-07T09:42:41Z

    fixing linelength and other issues

commit f29f564bb7fe7496b9f3d2f45a6b4469af559378
Author: Stefano Bortoli <s.bortoli@gmail.com>
Date:   2017-02-07T13:46:30Z

    Merge branch 'FLINK-5653' of https://github.com/huawei-flink/flink.git
    into FLINK-5653

commit ea145ecefc2be1bea71e995dbf39585e7fa44012
Author: rtudoran <tudoranradu@ymail.com>
Date:   2017-02-07T13:46:53Z

    Merge branch 'FLINK-5653' of https://github.com/huawei-flink/flink into FLINK-5654

commit 30749fc34d96a00427d079f803d44ba7007e619b
Author: rtudoran <tudoranradu@ymail.com>
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 <s.bortoli@gmail.com>
Date:   2017-02-09T14:06:48Z

    pushing Util function to synchronize with other branch

commit 41c9ed49359b2ae9ad552eb07e51c8a60c219e97
Author: rtudoran <tudoranradu@ymail.com>
Date:   2017-02-09T14:07:35Z

    Merge branch 'FLINK-5653' of https://github.com/huawei-flink/flink into FLINK-5654

commit 9c0dc0b17824ec967635c93974004533db3118b9
Author: rtudoran <tudoranradu@ymail.com>
Date:   2017-02-09T16:57:49Z

    partition verification

commit cb3d7050fff0e119c1e49b7b2ad5294774041091
Author: Stefano Bortoli <s.bortoli@gmail.com>
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 <s.bortoli@gmail.com>
Date:   2017-02-10T15:00:22Z

    Merge branch 'FLINK-5654' of https://github.com/huawei-flink/flink into
    # Conflicts:
    #	flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/logical/rel/util/WindowAggregateUtil.java

commit 4e8ad831a04347bb94fae23cbc576f23e81fca9d
Author: rtudoran <tudoranradu@ymail.com>
Date:   2017-02-10T16:21:56Z

    small progress for global window

commit 6079d9ede35ffa6297130a08764fcb69d2609fbd
Author: rtudoran <tudoranradu@ymail.com>
Date:   2017-02-10T16:28:31Z

    Merg conflict solved

commit 9ec8edf17988b5d2ac2e5fa428854ef9c99be1e4
Author: rtudoran <tudoranradu@ymail.com>
Date:   2017-02-10T16:37:04Z

    Build errors solved

commit 2d6ea54cdfe7096fcd6bbb8ae8bbdf2cd2ba2d0c
Author: Stefano Bortoli <s.bortoli@gmail.com>
Date:   2017-02-10T16:53:03Z

    fixing unused imports

commit da4992a7dccc1f7022c9adaca9adf70c56d36f8f
Author: rtudoran <tudoranradu@ymail.com>
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 <s.bortoli@gmail.com>
Date:   2017-02-28T15:52:35Z

    Adding aggregation functions in new package

commit 6b5aa7cc40e72a3bbd67b235fc6c2f75f2e6804b
Author: rtudoran <tudoranradu@ymail.com>
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 <s.bortoli@gmail.com>
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}
>   a, 
> 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

View raw message