This closes #2476
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a0da7bec Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a0da7bec Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a0da7bec Branch: refs/heads/master Commit: a0da7becae2ce4346f04d2194b5553333e41d0d1 Parents: 3f419db 8ef9861 Author: Aljoscha Krettek <[email protected]> Authored: Mon May 8 20:17:39 2017 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Mon May 8 20:17:39 2017 +0200 ---------------------------------------------------------------------- .../FlinkStreamingTransformTranslators.java | 54 +++++- .../wrappers/streaming/io/DedupingOperator.java | 187 +++++++++++++++++++ .../streaming/io/UnboundedSourceWrapper.java | 15 +- .../flink/streaming/DedupingOperatorTest.java | 131 +++++++++++++ .../streaming/UnboundedSourceWrapperTest.java | 29 +-- 5 files changed, 393 insertions(+), 23 deletions(-) ----------------------------------------------------------------------
