You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/20 00:20:00 UTC
[jira] [Commented] (SAMZA-1557) Broadcast operator

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

ASF GitHub Bot commented on SAMZA-1557:
---------------------------------------

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 <xi...@...>
Date:   2018-01-17T02:12:37Z

    SAMZA-1557: Broadcast operator

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

    Add integration tests

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

    Small enhancements

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

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

----


> Broadcast operator
> ------------------
>
>                 Key: SAMZA-1557
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1557
>             Project: Samza
>          Issue Type: Bug
>    Affects Versions: 0.15.0
>            Reporter: Xinyu Liu
>            Assignee: Xinyu Liu
>            Priority: Major
>             Fix For: 0.15.0
>
>
> Broadcast operator to broadcast 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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)