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 2018/12/18 18:26:54 UTC

[beam] branch master updated (af5d7bf -> 319a370)

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 af5d7bf  Merge pull request #7007 from coheigea/return
     add eab1d0e  [BEAM-6252] SamzaRunner: Add a registrar to allow customized DoFnInvoker
     add 6a6fbe4  Allow Samza DoFnInvoker to generate configs and pass in TaskContext
     new 319a370  Merge pull request #7301: [BEAM-6252] SamzaRunner: Add a registrar to allow customized DoFnInvoker

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../apache/beam/runners/samza/runtime/DoFnOp.java  | 12 +++++-
 ...Emitter.java => SamzaDoFnInvokerRegistrar.java} | 18 +++++----
 .../translation/ParDoBoundMultiTranslator.java     | 17 ++++++++
 .../samza/translation/TranslationContext.java      | 47 +++++++++++++++++++---
 .../runners/samza/util/PipelineDotRenderer.java    |  3 +-
 5 files changed, 83 insertions(+), 14 deletions(-)
 copy runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/{OpEmitter.java => SamzaDoFnInvokerRegistrar.java} (61%)

[beam] 01/01: Merge pull request #7301: [BEAM-6252] SamzaRunner: Add a registrar to allow customized DoFnInvoker

Posted by xi...@apache.org.

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

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

commit 319a3709912bed66d567f0e4e2b9da8c73f47e5d
Merge: af5d7bf 6a6fbe4
Author: xinyuiscool <xi...@gmail.com>
AuthorDate: Tue Dec 18 10:26:45 2018 -0800

    Merge pull request #7301: [BEAM-6252] SamzaRunner: Add a registrar to allow customized DoFnInvoker

 .../apache/beam/runners/samza/runtime/DoFnOp.java  | 12 +++++-
 .../samza/runtime/SamzaDoFnInvokerRegistrar.java   | 34 ++++++++++++++++
 .../translation/ParDoBoundMultiTranslator.java     | 17 ++++++++
 .../samza/translation/TranslationContext.java      | 47 +++++++++++++++++++---
 .../runners/samza/util/PipelineDotRenderer.java    |  3 +-
 5 files changed, 106 insertions(+), 7 deletions(-)