beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From charlesccychen <>
Subject [GitHub] beam pull request #3157: [BEAM-1265] Do not merge: streaming scratch work
Date Tue, 16 May 2017 00:10:51 GMT
GitHub user charlesccychen opened a pull request:

    [BEAM-1265] Do not merge: streaming scratch work

    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`.
     - [ ] 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 streaming-test

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 #3157
commit f78e47ca47e19ac2684c13bf13dbb66e65f04048
Author: Charles Chen <>
Date:   2017-04-19T01:20:07Z

    streaming test

commit dd3966a572b73ffa9421a176cc03f096707cdb0d
Author: Charles Chen <>
Date:   2017-04-20T05:54:02Z

    Working TestStream evaluator

commit 68b5a84595f4ca9adc131fe2fcee38f91078a047
Author: Charles Chen <>
Date:   2017-04-20T08:59:05Z

    Slightly better watermark propagation, debugging print cleanup.

commit 48d4f1ef68829e98e964070f60ce9470528fcb0e
Author: Charles Chen <>
Date:   2017-04-20T09:44:19Z

    Factor out GroupAlsoByWindows so that it can be overridden by the DirectRunner.

commit b5e7073b66c02f634a4bdec8f787b38bb923d52a
Author: Charles Chen <>
Date:   2017-04-21T05:51:27Z

    Don't buffer elements in GroupByKeyOnly.

commit f81c2d0b536e2715fe4cd278359eed5c6a855dc5
Author: Charles Chen <>
Date:   2017-04-21T17:33:03Z

    Skeleton implementation of GroupAlsoByKeyEvaluator.

commit 05bd9c677c89d3d3413c205a2965ec0cc6827786
Author: Charles Chen <>
Date:   2017-04-22T08:32:25Z

    Mostly working streaming GroupAlsoByWindow.

commit f9197ff807d27e61eef337b261f826d5f4b43908
Author: Charles Chen <>
Date:   2017-04-24T08:58:58Z

    Introduce keyed bundles, KeyedWorkItems.

commit c4b6faf9a4b8231616ec35ec2fd766b863e7a76e
Author: Charles Chen <>
Date:   2017-04-24T15:16:05Z

    Rename old non-keyed state to legacy_state, introduce KeyedWorkItem, prepare to expose
DirectUnmergedState API.


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 or file a JIRA ticket
with INFRA.

View raw message