beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [1/2] incubator-beam git commit: This closes #1569
Date Tue, 20 Dec 2016 23:19:36 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 6a05d7f17 -> aadcf3a12


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/master
Commit: aadcf3a1203b257961a1a474acf74e6bbca1e2ad
Parents: 6a05d7f 34373c2
Author: Thomas Groh <tgroh@google.com>
Authored: Tue Dec 20 15:18:55 2016 -0800
Committer: Thomas Groh <tgroh@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(-)
----------------------------------------------------------------------



Mime
View raw message