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 <bchamb...@google.com> Authored: Tue Jan 3 13:15:50 2017 -0800 Committer: bchambers <bchamb...@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(-) ----------------------------------------------------------------------