flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljoscha <...@git.apache.org>
Subject [GitHub] flink pull request: [FLINK-2778] Add API for non-parallel non-keye...
Date Tue, 29 Sep 2015 20:30:48 GMT
GitHub user aljoscha opened a pull request:

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

    [FLINK-2778] Add API for non-parallel non-keyed Windows

    This adds two new operators for non-keyed windows: Regular trigger
    operator and evicting trigger operator.
    
    This also adds the API calls nonParallelWindow(...) on DataStream and
    the API class NonParallelWindowDataStream for representing these
    operations.
    
    This also adds tests for both the operators and the translation from API
    to operators.

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

    $ git pull https://github.com/aljoscha/flink non-parallel-window

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

    https://github.com/apache/flink/pull/1196.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 #1196
    
----
commit c0f4665ee57ffd7d7cc57012aa1dc5f6bdd81081
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Date:   2015-09-29T18:22:11Z

    [hotfix] Simplify new windowing API
    
    Before, there would be three different window() methods on
    KeyedDataStream: one that takes two policies, one that takes one policy
    and one that takes a window assigner.
    
    Now, there is only one window() method that takes a window assigner and
    creates a KeyedWindowDataStream.
    
    For conveniece, there are two methods timeWindows() that take either one
    argument (tumbling windows) or two arguments (sliding windows). These
    create a KeyedWindowDataStream with either a SlidingWindows or
    TumblingWindows assigner.
    
    When the window operator is created we pick the optimized aligned time
    windows operator if the combination of window assigner/trigger/evictor
    allows it.
    
    All of this behaviour is verified in tests.

commit 24a70078fe2622c75376e590c07e8eeb7972f430
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Date:   2015-09-29T18:29:09Z

    [FLINK-2778] Add API for non-parallel non-keyed Windows
    
    This adds two new operators for non-keyed windows: Regular trigger
    operator and evicting trigger operator.
    
    This also adds the API calls nonParallelWindow(...) on DataStream and
    the API class NonParallelWindowDataStream for representing these
    operations.
    
    This also adds tests for both the operators and the translation from API
    to operators.

----


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