This closes #1164
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8883877a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8883877a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8883877a Branch: refs/heads/master Commit: 8883877ae91fa42963181d419d8f3cbfea8b314b Parents: facf096 8183ac8 Author: Jesse Anderson <je...@smokinghand.com> Authored: Tue Nov 1 19:25:27 2016 -0600 Committer: Jesse Anderson <je...@smokinghand.com> Committed: Tue Nov 1 19:25:27 2016 -0600 ---------------------------------------------------------------------- .../apache/beam/examples/complete/TfIdf.java | 6 +- .../beam/examples/cookbook/DeDupExample.java | 8 +- .../org/apache/beam/examples/cookbook/README.md | 2 +- .../beam/examples/complete/TfIdfTest.java | 4 +- .../examples/cookbook/DeDupExampleTest.java | 82 ---------- .../examples/cookbook/DistinctExampleTest.java | 82 ++++++++++ .../UnboundedReadFromBoundedSourceTest.java | 4 +- .../beam/runners/flink/examples/TFIDF.java | 6 +- .../streaming/KafkaStreamingTest.java | 4 +- .../sdk/io/BoundedReadFromUnboundedSource.java | 4 +- .../apache/beam/sdk/transforms/Distinct.java | 158 ++++++++++++++++++ .../beam/sdk/transforms/RemoveDuplicates.java | 159 ------------------- .../apache/beam/sdk/io/CountingInputTest.java | 6 +- .../apache/beam/sdk/io/CountingSourceTest.java | 8 +- .../sdk/transforms/ApproximateUniqueTest.java | 2 +- .../beam/sdk/transforms/DistinctTest.java | 130 +++++++++++++++ .../sdk/transforms/RemoveDuplicatesTest.java | 130 --------------- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 6 +- .../beam/sdk/transforms/DistinctJava8Test.java | 104 ++++++++++++ .../transforms/RemoveDuplicatesJava8Test.java | 104 ------------ 20 files changed, 504 insertions(+), 505 deletions(-) ----------------------------------------------------------------------
