flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gyfora <...@git.apache.org>
Subject [GitHub] flink pull request: Periodic full stream aggregates added + partit...
Date Tue, 21 Apr 2015 11:23:54 GMT
GitHub user gyfora opened a pull request:

    https://github.com/apache/flink/pull/614

    Periodic full stream aggregates added + partitioner bugfix

    This PR introduces periodic full stream aggregates on data streams as a special case of
windowing.
    
    Usage:
    
    dataStream.every(trigger).reduce(..)
    dataStream.every(trigger).sum/max/min/...
    
    or
    
    dataStream.window(FullStream.window()).every()
    
    It only allows aggregations  so we dont need to keep the full history in a buffer.
    It also works together with parallel time discretization.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/mbalassi/flink FullStream-window

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/614.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 #614
    
----
commit 57f91d8d8e5a2bd96df2f12d8cd5c04d08cdb964
Author: Gyula Fora <gyfora@apache.org>
Date:   2015-04-21T11:20:03Z

    [streaming] FullStream window helper added + partitioner bugfix

----


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