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 2021/08/12 18:55:37 UTC

[beam] branch master updated (dcf5e8e -> 2b96f43)

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 dcf5e8e  Merge pull request #15233: Loosen typing extensions requirement
     add 2b96f43  [BEAM-12453]: Add interface to access I/O topic information for a Samza Beam job and PipelineJsonRenderer to create the JSON Beam DAG (#14945)

No new revisions were added by this update.

Summary of changes:
 runners/samza/build.gradle                         |   1 +
 .../org/apache/beam/runners/samza/SamzaRunner.java |  19 +-
 .../runners/samza/util/PipelineJsonRenderer.java   | 209 +++++++++++++++++++++
 .../samza/util/PipelineJsonRendererTest.java       | 105 +++++++++++
 runners/samza/src/test/resources/ExpectedDag.json  |  68 +++++++
 5 files changed, 400 insertions(+), 2 deletions(-)
 create mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/PipelineJsonRenderer.java
 create mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/util/PipelineJsonRendererTest.java
 create mode 100644 runners/samza/src/test/resources/ExpectedDag.json