beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xi...@apache.org
Subject [beam] branch master updated (dcf5e8e -> 2b96f43)
Date Thu, 12 Aug 2021 18:55:37 GMT
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

Mime
View raw message