This closes #126
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/eb682a80 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/eb682a80 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/eb682a80 Branch: refs/heads/master Commit: eb682a80c4091dce5242ebc8272f43f3461a6fc5 Parents: d440d94 b0baa4c Author: bchambers <bchamb...@google.com> Authored: Fri Apr 15 14:29:30 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Fri Apr 15 14:29:30 2016 -0700 ---------------------------------------------------------------------- .../sdk/transforms/ApproximateQuantiles.java | 8 + .../beam/sdk/transforms/ApproximateUnique.java | 44 ++++++ .../org/apache/beam/sdk/transforms/Combine.java | 155 +++++++++++++++---- .../beam/sdk/transforms/CombineFnBase.java | 27 +++- .../apache/beam/sdk/transforms/CombineFns.java | 65 ++++++++ .../beam/sdk/transforms/CombineWithContext.java | 6 + .../org/apache/beam/sdk/transforms/Max.java | 6 + .../org/apache/beam/sdk/transforms/Min.java | 6 + .../org/apache/beam/sdk/transforms/Sample.java | 14 ++ .../org/apache/beam/sdk/transforms/Top.java | 8 + .../sdk/transforms/display/ClassForDisplay.java | 93 +++++++++++ .../sdk/transforms/display/DisplayData.java | 111 +++++++++++-- .../org/apache/beam/sdk/util/CombineFnUtil.java | 13 ++ .../transforms/ApproximateQuantilesTest.java | 13 ++ .../sdk/transforms/ApproximateUniqueTest.java | 17 ++ .../beam/sdk/transforms/CombineFnsTest.java | 69 ++++++++- .../apache/beam/sdk/transforms/CombineTest.java | 22 ++- .../org/apache/beam/sdk/transforms/MaxTest.java | 13 +- .../org/apache/beam/sdk/transforms/MinTest.java | 13 +- .../apache/beam/sdk/transforms/SampleTest.java | 14 ++ .../org/apache/beam/sdk/transforms/TopTest.java | 13 ++ .../transforms/display/ClassForDisplayTest.java | 66 ++++++++ .../transforms/display/DisplayDataMatchers.java | 51 +++--- .../sdk/transforms/display/DisplayDataTest.java | 18 ++- .../display/ClassForDisplayJava8Test.java | 46 ++++++ .../beam/sdk/transforms/CombineJava8Test.java | 42 +++++ 26 files changed, 878 insertions(+), 75 deletions(-) ----------------------------------------------------------------------