GitHub user xinyuiscool opened a pull request:
https://github.com/apache/samza/pull/410
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 https://github.com/xinyuiscool/samza SAMZA-1557
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/410.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 #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
----
---
