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(-) ----------------------------------------------------------------------