You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by je...@apache.org on 2016/11/02 02:41:53 UTC
[2/2] incubator-beam git commit: This closes #1164
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(-)
----------------------------------------------------------------------