samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xinyuiscool <>
Subject [GitHub] samza pull request #410: SAMZA-1557: Broadcast operator
Date Sat, 20 Jan 2018 00:19:41 GMT
GitHub user xinyuiscool opened a pull request:

    SAMZA-1557: Broadcast operator

    This patch adds Broadcast operator that allows broadcasting messages to all tasks. It's
the counterpart of the Samza broadcast stream in low level api, and will be used by BEAM runner
to broadcast views as side input to other part of the pipeline.

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

    $ git pull SAMZA-1557

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 #410
commit 58d7c37d17dd144c4d009311811e4e77ce19d1f0
Author: xiliu <xiliu@...>
Date:   2018-01-17T02:12:37Z

    SAMZA-1557: Broadcast operator

commit f3f40f6b5af957f9c9fc6e35e4fc1eb50672d0c0
Author: xiliu <xiliu@...>
Date:   2018-01-18T23:09:14Z

    Add integration tests

commit a1c7100d243f22dae1de3d4e8004043dc79bb681
Author: xiliu <xiliu@...>
Date:   2018-01-18T23:47:21Z

    Small enhancements

commit 23bcada447d19fb2103db61ac2b0daa632ff6707
Author: xiliu <xiliu@...>
Date:   2018-01-20T00:04:52Z

    Some minor fix to compute the output to input mapping for broadcast op



View raw message