This closes #1569
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/aadcf3a1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/aadcf3a1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/aadcf3a1 Branch: refs/heads/python-sdk Commit: aadcf3a1203b257961a1a474acf74e6bbca1e2ad Parents: 6a05d7f 34373c2 Author: Thomas Groh <tg...@google.com> Authored: Tue Dec 20 15:18:55 2016 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Tue Dec 20 15:18:55 2016 -0800 ---------------------------------------------------------------------- .../beam/runners/direct/DirectGraphVisitor.java | 18 +-- .../beam/runners/direct/EvaluationContext.java | 7 +- .../direct/KeyedPValueTrackingVisitor.java | 16 ++- .../beam/runners/direct/WatermarkManager.java | 19 +-- .../apache/beam/runners/spark/SparkRunner.java | 13 ++- .../beam/sdk/runners/TransformHierarchy.java | 49 ++++---- .../transforms/join/KeyedPCollectionTuple.java | 9 +- .../java/org/apache/beam/sdk/values/PBegin.java | 4 +- .../apache/beam/sdk/values/PCollectionList.java | 65 +++++++---- .../beam/sdk/values/PCollectionTuple.java | 28 ++++- .../java/org/apache/beam/sdk/values/PDone.java | 4 +- .../java/org/apache/beam/sdk/values/PInput.java | 4 +- .../org/apache/beam/sdk/values/POutput.java | 4 +- .../java/org/apache/beam/sdk/values/PValue.java | 10 ++ .../org/apache/beam/sdk/values/PValueBase.java | 11 +- .../apache/beam/sdk/values/TaggedPValue.java | 42 +++++++ .../sdk/runners/TransformHierarchyTest.java | 23 +++- .../apache/beam/sdk/transforms/ParDoTest.java | 34 ++++++ .../beam/sdk/values/PCollectionListTest.java | 117 +++++++++++++++++++ .../beam/sdk/values/PCollectionTupleTest.java | 70 +++++++++++ 20 files changed, 449 insertions(+), 98 deletions(-) ----------------------------------------------------------------------