beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [1/4] beam git commit: This closes #2248
Date Fri, 17 Mar 2017 15:54:29 GMT
Repository: beam
Updated Branches:
  refs/heads/master 969acb7da -> ef6a5008a


This closes #2248


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

Branch: refs/heads/master
Commit: ef6a5008a012582a02007a630e78a7716e3175c3
Parents: 969acb7 c6cad20
Author: Thomas Groh <tgroh@google.com>
Authored: Fri Mar 17 08:54:02 2017 -0700
Committer: Thomas Groh <tgroh@google.com>
Committed: Fri Mar 17 08:54:02 2017 -0700

----------------------------------------------------------------------
 .../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 +++++++++++++++++++
 runners/core-construction-java/pom.xml          |   7 +
 .../core/construction/ForwardingPTransform.java |  62 ++++
 .../construction/ForwardingPTransformTest.java  | 111 ++++++
 .../beam/runners/direct/DirectGroupByKey.java   |   1 +
 .../beam/runners/direct/DirectRunner.java       |  18 +-
 .../runners/direct/ForwardingPTransform.java    |  62 ----
 .../ParDoSingleViaMultiOverrideFactory.java     |  70 ----
 .../runners/direct/ViewEvaluatorFactory.java    |   1 +
 .../direct/ForwardingPTransformTest.java        | 112 ------
 .../ParDoSingleViaMultiOverrideFactoryTest.java |  46 ---
 .../flink/FlinkBatchTransformTranslators.java   |  78 +----
 .../FlinkStreamingTransformTranslators.java     | 113 +-----
 .../dataflow/DataflowPipelineTranslator.java    |   9 +-
 .../beam/runners/dataflow/DataflowRunner.java   |   3 +-
 .../dataflow/PrimitiveParDoSingleFactory.java   |  77 +++++
 .../DataflowPipelineTranslatorTest.java         |   9 +-
 .../PrimitiveParDoSingleFactoryTest.java        | 126 +++++++
 .../spark/translation/TransformTranslator.java  | 100 +++---
 .../streaming/StreamingTransformTranslator.java | 168 ++++-----
 .../streaming/TrackStreamingSourcesTest.java    |   4 +-
 .../org/apache/beam/sdk/transforms/ParDo.java   |   8 +-
 28 files changed, 1071 insertions(+), 1273 deletions(-)
----------------------------------------------------------------------



Mime
View raw message