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 #2170
Date Mon, 06 Mar 2017 17:09:23 GMT
This closes #2170


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

Branch: refs/heads/master
Commit: 9cc8018b3ed945244bb311134ebd824016d1633f
Parents: 34b38ef 8766b03
Author: Thomas Groh <tgroh@google.com>
Authored: Mon Mar 6 09:09:10 2017 -0800
Committer: Thomas Groh <tgroh@google.com>
Committed: Mon Mar 6 09:09: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, 1079 insertions(+), 668 deletions(-)
----------------------------------------------------------------------



Mime
View raw message