beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <>
Subject [jira] [Commented] (BEAM-920) Support triggers, panes and watermarks.
Date Mon, 20 Feb 2017 17:53:44 GMT


ASF GitHub Bot commented on BEAM-920:

GitHub user amitsela opened a pull request:

    [BEAM-920] Support triggers, panes and watermarks.

    Be sure to do all of the following to help us incorporate your contribution
    quickly and easily:
     - [ ] Make sure the PR title is formatted like:
       `[BEAM-<Jira issue #>] Description of pull request`
     - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
           Travis-CI on your fork and ensure the whole test matrix passes).
     - [ ] Replace `<Jira issue #>` in the title with the actual Jira issue
           number, if there is one.
     - [ ] If this contribution is large, please file an Apache
           [Individual Contributor License Agreement](

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

    $ git pull BEAM-920

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 #2050
commit f5d23531de20b64164496e39f01bc964176501c6
Author: Sela <>
Date:   2017-02-13T14:30:16Z

    Better name for batch implementation of GroupAlsoByWindow.

commit 9bb666f794b3179683f1e70e93fb4cf7e7ad7067
Author: Sela <>
Date:   2017-02-13T14:32:21Z

    Implementation of GroupAlsoByWindowViaWindowSet for the Spark runner.

commit 1bdc69ae84b39ef8b71f095a5ac14f0bfeca38ef
Author: Sela <>
Date:   2017-02-13T14:33:14Z

    Utils for SparkGroupAlsoByWindowViaWindowSet.

commit 7b93356216d174cb4e2ced46e7a58de9932ac8b6
Author: Sela <>
Date:   2017-02-16T23:19:23Z

    Refactor translators according to new GroupAlsoByWindow implemenation for the Spark runnner.

commit 9a87206c1750b6c92f2787fd991d9d5b519e5a4f
Author: Sela <>
Date:   2017-02-18T20:01:58Z

    Fix streaming translation of Flatten and Window, make CreateStream eager.

commit 2a9fdd914e017a42b4b8a07937294d67324f4a3a
Author: Sela <>
Date:   2017-02-18T20:05:19Z

    Test triggers, panes and watermarks via CreateStream.

commit 9f15cf81c7469431d08c0f297d496edc6c85d86f
Author: Sela <>
Date:   2017-02-18T20:06:51Z

    Remove streaming tests that were needed before supporting the model.

commit 01a4da64ca328645e78c74edde3375326d00008c
Author: Sela <>
Date:   2017-02-18T20:10:50Z

    Use TestSparkRunner in tests.

commit 700907ff0757b25f20d3acb83eff715359775c5e
Author: Sela <>
Date:   2017-02-18T20:12:39Z

    Handle test failures in "graceful stop peroid".

commit 1b21ed4594ccba1a6cb249433f577374f19dc531
Author: Sela <>
Date:   2017-02-18T20:13:29Z

    Further refactoring following changes.

commit bfe6594143a2cd830c5a7a2a2923a906c9855ac2
Author: Sela <>
Date:   2017-02-19T22:13:23Z

    Serialize state stream with coders for shuffle and checkpointing.

commit 173e29b0ad70b2f891ab6c74b740850eb6c01139
Author: Sela <>
Date:   2017-02-19T22:14:39Z

    Add multi stream and flattened stream tests.

commit 4cfa372927bc77c74469de702eb13efe70560650
Author: Sela <>
Date:   2017-02-20T12:00:54Z

    Misc. fixups.

commit 5788190aed2def9b8028f3759d160b2d38f32547
Author: Sela <>
Date:   2017-02-20T17:45:03Z

    Make TimestampTransform Serializable.

commit 462f7b22b94d3528fff0a086f87a25630b748ca1
Author: Sela <>
Date:   2017-02-20T17:47:45Z

    Rebase leftover fixes.


> Support triggers, panes and watermarks.
> ---------------------------------------
>                 Key: BEAM-920
>                 URL:
>             Project: Beam
>          Issue Type: New Feature
>          Components: runner-spark
>            Reporter: Amit Sela
>            Assignee: Amit Sela
> Implement event-time based aggregation using triggers, panes and watermarks.

This message was sent by Atlassian JIRA

View raw message