You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2016/12/21 23:26:39 UTC
[3/3] incubator-beam git commit: This closes #1582
This closes #1582
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7984fe3f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7984fe3f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7984fe3f
Branch: refs/heads/master
Commit: 7984fe3fc20160d2286433434190f35658aef158
Parents: 57d9bbd 038950d
Author: Thomas Groh <tg...@google.com>
Authored: Wed Dec 21 15:26:18 2016 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Wed Dec 21 15:26:18 2016 -0800
----------------------------------------------------------------------
.../translation/ParDoBoundTranslatorTest.java | 32 ++++----
.../beam/runners/direct/DirectGraphVisitor.java | 21 ------
.../beam/runners/direct/DirectRunner.java | 1 -
.../runners/direct/DirectGraphVisitorTest.java | 32 +-------
.../direct/FlattenEvaluatorFactoryTest.java | 2 +
.../direct/KeyedPValueTrackingVisitorTest.java | 17 ++++-
.../beam/runners/spark/ForceStreamingTest.java | 41 +---------
.../main/java/org/apache/beam/sdk/Pipeline.java | 3 +
.../beam/sdk/runners/TransformHierarchy.java | 45 ++++++-----
.../transforms/join/KeyedPCollectionTuple.java | 32 ++++----
.../java/org/apache/beam/sdk/values/PBegin.java | 5 --
.../apache/beam/sdk/values/PCollectionList.java | 13 +---
.../beam/sdk/values/PCollectionTuple.java | 13 +---
.../java/org/apache/beam/sdk/values/PInput.java | 9 ---
.../org/apache/beam/sdk/values/POutput.java | 20 ++---
.../beam/sdk/values/POutputValueBase.java | 4 +-
.../java/org/apache/beam/sdk/values/PValue.java | 15 ++++
.../org/apache/beam/sdk/values/PValueBase.java | 3 +-
.../org/apache/beam/sdk/values/TypedPValue.java | 78 +++++++++++---------
.../sdk/runners/TransformHierarchyTest.java | 34 +++++----
.../apache/beam/sdk/transforms/ParDoTest.java | 7 +-
.../apache/beam/sdk/values/TypedPValueTest.java | 7 +-
22 files changed, 187 insertions(+), 247 deletions(-)
----------------------------------------------------------------------