You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/12/21 22:50:05 UTC
[31/51] [abbrv] incubator-beam git commit: This closes #1569
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(-)
----------------------------------------------------------------------