beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [beam] branch master updated (b917a86 -> e2e31c9)
Date Mon, 03 Dec 2018 19:10:11 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from b917a86  Merge pull request #7180: [BEAM-6146] Run pre-commit wordcount in batch
and streaming mode
     add f040a4e  [BEAM-5859] Improve operator names for portable pipelines
     add e2e31c9  Merge pull request #7150: [BEAM-5859] Improve operator names for portable
pipelines

No new revisions were added by this update.

Summary of changes:
 .../construction/ExecutableStageTranslation.java   | 21 ++++++
 .../ExecutableStageTranslationTest.java            | 83 ++++++++++++++++++++++
 .../FlinkBatchPortablePipelineTranslator.java      | 24 ++++---
 .../FlinkStreamingPortablePipelineTranslator.java  | 16 +++--
 .../FlinkPipelineTranslatorUtilsTest.java}         | 36 +++++-----
 5 files changed, 143 insertions(+), 37 deletions(-)
 create mode 100644 runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/ExecutableStageTranslationTest.java
 copy runners/{google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/apiary/ApiaryTest.java
=> flink/src/test/java/org/apache/beam/runners/flink/translation/FlinkPipelineTranslatorUtilsTest.java}
(50%)


Mime
View raw message