You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by xi...@apache.org on 2019/10/24 22:06:45 UTC

[beam] branch master updated (f67e3d8 -> a9cace3)

This is an automated email from the ASF dual-hosted git repository.

xinyu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from f67e3d8  Merge pull request #8496 from [BEAM-5967] Add handling of DynamicMessage in ProtoCoder
     add a9cace3  [BEAM-8341]: basic bundling support for portable runner (#9777)

No new revisions were added by this update.

Summary of changes:
 .../beam/runners/samza/SamzaPipelineOptions.java   |  12 ++
 .../samza/SamzaPipelineOptionsValidator.java       |  41 +++++-
 .../org/apache/beam/runners/samza/SamzaRunner.java |   7 +-
 .../apache/beam/runners/samza/runtime/DoFnOp.java  | 141 ++++++++++++++++++---
 .../beam/runners/samza/runtime/GroupByKeyOp.java   |   6 +-
 .../org/apache/beam/runners/samza/runtime/Op.java  |   2 +-
 .../beam/runners/samza/runtime/OpAdapter.java      |   2 +-
 .../runners/samza/runtime/SamzaDoFnRunners.java    |  74 ++++++++---
 .../translation/ParDoBoundMultiTranslator.java     |   2 +
 .../samza/translation/SamzaPipelineTranslator.java |   4 +
 10 files changed, 243 insertions(+), 48 deletions(-)