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 #2006
Date Fri, 17 Feb 2017 02:58:12 GMT
This closes #2006


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

Branch: refs/heads/master
Commit: 2ca3bf6690b4e9613bfcd4d3420c8da412a0ec7a
Parents: 41b2409 77a1afb
Author: Thomas Groh <tgroh@google.com>
Authored: Thu Feb 16 18:57:58 2017 -0800
Committer: Thomas Groh <tgroh@google.com>
Committed: Thu Feb 16 18:57:58 2017 -0800

----------------------------------------------------------------------
 .../translation/ParDoBoundMultiTranslator.java  |  5 ++
 .../apex/translation/ParDoBoundTranslator.java  |  5 ++
 .../beam/runners/direct/DirectRunner.java       | 88 ++++++++++++--------
 .../beam/runners/direct/EvaluationContext.java  |  3 +-
 .../direct/TestStreamEvaluatorFactory.java      |  3 +-
 .../direct/WriteWithShardingFactory.java        | 24 +++---
 .../beam/runners/direct/DirectRunnerTest.java   |  3 +-
 .../direct/KeyedPValueTrackingVisitorTest.java  | 23 ++++-
 .../StatefulParDoEvaluatorFactoryTest.java      | 57 ++++++++-----
 .../direct/TestStreamEvaluatorFactoryTest.java  | 20 ++---
 .../direct/ViewEvaluatorFactoryTest.java        |  4 +-
 .../FlinkBatchTransformTranslators.java         | 12 +++
 .../FlinkStreamingTransformTranslators.java     | 12 +++
 .../dataflow/DataflowPipelineTranslator.java    |  7 ++
 .../spark/translation/TransformTranslator.java  |  3 +
 .../spark/translation/TranslationUtils.java     |  9 ++
 .../streaming/StreamingTransformTranslator.java |  3 +
 .../beam/sdk/runners/TransformHierarchy.java    | 28 ++++++-
 .../org/apache/beam/sdk/testing/TestStream.java | 10 +--
 .../org/apache/beam/sdk/transforms/ParDo.java   |  9 +-
 .../apache/beam/sdk/testing/TestStreamTest.java | 17 ----
 .../apache/beam/sdk/transforms/ParDoTest.java   | 30 -------
 22 files changed, 225 insertions(+), 150 deletions(-)
----------------------------------------------------------------------



Mime
View raw message