flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From huawei-flink <...@git.apache.org>
Subject [GitHub] flink pull request #3459: [FLINK-5654] Add processing time OVER RANGE BETWEE...
Date Thu, 02 Mar 2017 16:53:12 GMT
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 <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
    branch

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
    
    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 <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
    FLINK-5653
    
    # 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

----


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message