You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2017/01/03 21:28:02 UTC
[4/4] beam git commit: Closes #1718

Closes #1718


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6c1e4697
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6c1e4697
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6c1e4697

Branch: refs/heads/master
Commit: 6c1e4697640ab2a5053adb96083918a39fb3b744
Parents: 0616245 16b2667
Author: bchambers <bc...@google.com>
Authored: Tue Jan 3 13:15:50 2017 -0800
Committer: bchambers <bc...@google.com>
Committed: Tue Jan 3 13:15:50 2017 -0800

----------------------------------------------------------------------
 .../core/UnboundedReadFromBoundedSource.java    |   4 +-
 .../beam/runners/dataflow/DataflowRunner.java   |   9 +-
 .../DataflowUnboundedReadFromBoundedSource.java |  11 +-
 .../sdk/io/BoundedReadFromUnboundedSource.java  |   5 +-
 .../main/java/org/apache/beam/sdk/io/Read.java  |   7 +-
 .../org/apache/beam/sdk/transforms/Combine.java | 175 +++++++++---------
 .../org/apache/beam/sdk/transforms/Count.java   |   4 +-
 .../org/apache/beam/sdk/transforms/Max.java     |  20 +-
 .../org/apache/beam/sdk/transforms/Mean.java    |   4 +-
 .../org/apache/beam/sdk/transforms/Min.java     |  20 +-
 .../apache/beam/sdk/transforms/PTransform.java  |   4 +-
 .../org/apache/beam/sdk/transforms/ParDo.java   |  46 ++---
 .../org/apache/beam/sdk/transforms/Sum.java     |  12 +-
 .../org/apache/beam/sdk/transforms/Top.java     |  27 +--
 .../org/apache/beam/sdk/util/NameUtils.java     | 162 +++++++++++++++++
 .../org/apache/beam/sdk/util/StringUtils.java   | 100 ----------
 .../org/apache/beam/sdk/values/PValueBase.java  |   4 +-
 .../apache/beam/sdk/transforms/CombineTest.java |  23 +--
 .../apache/beam/sdk/transforms/CountTest.java   |   2 +-
 .../org/apache/beam/sdk/transforms/MaxTest.java |  14 +-
 .../apache/beam/sdk/transforms/MeanTest.java    |   5 +-
 .../org/apache/beam/sdk/transforms/MinTest.java |  15 +-
 .../org/apache/beam/sdk/transforms/SumTest.java |  12 +-
 .../org/apache/beam/sdk/transforms/TopTest.java |  13 +-
 .../org/apache/beam/sdk/util/NameUtilsTest.java | 181 +++++++++++++++++++
 .../apache/beam/sdk/util/StringUtilsTest.java   | 100 ----------
 26 files changed, 544 insertions(+), 435 deletions(-)
----------------------------------------------------------------------