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:55 UTC

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

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(-)