beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [3/3] beam git commit: This closes #2145
Date Fri, 03 Mar 2017 23:36:28 GMT
This closes #2145


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bb8cd72b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bb8cd72b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bb8cd72b

Branch: refs/heads/master
Commit: bb8cd72b98b261c781add91191d246a650de2cd3
Parents: 7e9233b 6253aba
Author: Thomas Groh <tgroh@google.com>
Authored: Fri Mar 3 15:36:10 2017 -0800
Committer: Thomas Groh <tgroh@google.com>
Committed: Fri Mar 3 15:36:10 2017 -0800

----------------------------------------------------------------------
 .../translation/ApexPipelineTranslator.java     |   3 +-
 .../translation/ParDoBoundMultiTranslator.java  | 185 ----------
 .../apex/translation/ParDoBoundTranslator.java  |  95 -----
 .../apex/translation/ParDoTranslator.java       | 185 ++++++++++
 .../FlattenPCollectionTranslatorTest.java       |   3 +-
 .../translation/ParDoBoundTranslatorTest.java   | 344 -------------------
 .../apex/translation/ParDoTranslatorTest.java   | 344 +++++++++++++++++++
 .../beam/runners/direct/DirectRunner.java       |  18 +-
 .../ParDoSingleViaMultiOverrideFactory.java     |  70 ----
 .../ParDoSingleViaMultiOverrideFactoryTest.java |  46 ---
 .../flink/FlinkBatchTransformTranslators.java   |  78 +----
 .../FlinkStreamingTransformTranslators.java     | 113 +-----
 .../dataflow/DataflowPipelineTranslator.java    |  29 --
 .../DataflowPipelineTranslatorTest.java         |   7 +-
 .../spark/translation/TransformTranslator.java  | 100 +++---
 .../streaming/StreamingTransformTranslator.java | 115 ++++---
 .../streaming/TrackStreamingSourcesTest.java    |   4 +-
 .../org/apache/beam/sdk/transforms/ParDo.java   |   8 +-
 18 files changed, 668 insertions(+), 1079 deletions(-)
----------------------------------------------------------------------



Mime
View raw message