[jira] [Commented] (FLINK-2778) Add API for non-parallel non-keyed Windows

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-2778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14935801#comment-14935801 ] 

ASF GitHub Bot commented on FLINK-2778:
---------------------------------------

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 <al...@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 <al...@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.

----


> Add API for non-parallel non-keyed Windows
> ------------------------------------------
>
>                 Key: FLINK-2778
>                 URL: https://issues.apache.org/jira/browse/FLINK-2778
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Streaming
>            Reporter: Aljoscha Krettek
>            Assignee: Aljoscha Krettek
>             Fix For: 0.10
>
>
> This addresses the NonParallelWindowStream section in the design doc: https://cwiki.apache.org/confluence/display/FLINK/Streams+and+Operations+on+Streams



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)