Closes #473
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c83e5c48 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c83e5c48 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c83e5c48 Branch: refs/heads/master Commit: c83e5c48f002003f60e06a3dd41c83aa2a702a9a Parents: 3bc0fe6 569228e Author: Dan Halperin <dhalp...@google.com> Authored: Wed Jun 22 09:57:24 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Wed Jun 22 09:57:24 2016 -0700 ---------------------------------------------------------------------- .../direct/UnboundedReadDeduplicator.java | 102 ++++++++++++++ .../direct/UnboundedReadEvaluatorFactory.java | 17 ++- .../direct/UnboundedReadDeduplicatorTest.java | 134 +++++++++++++++++++ .../UnboundedReadEvaluatorFactoryTest.java | 50 ++++++- 4 files changed, 299 insertions(+), 4 deletions(-) ----------------------------------------------------------------------
