You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by th...@apache.org on 2018/12/03 19:10:11 UTC

[beam] branch master updated (b917a86 -> e2e31c9)

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