beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [1/2] beam git commit: This closes #2959
Date Mon, 08 May 2017 23:41:43 GMT
Repository: beam
Updated Branches:
  refs/heads/release-2.0.0 5493c6c8f -> 336b3dc29


This closes #2959


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/336b3dc2
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/336b3dc2
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/336b3dc2

Branch: refs/heads/release-2.0.0
Commit: 336b3dc29b5de0f8affc71fbe9886a3e0ee2a0fe
Parents: 5493c6c 392ed60
Author: Thomas Groh <tgroh@google.com>
Authored: Mon May 8 16:41:25 2017 -0700
Committer: Thomas Groh <tgroh@google.com>
Committed: Mon May 8 16:41:25 2017 -0700

----------------------------------------------------------------------
 .../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(-)
----------------------------------------------------------------------



Mime
View raw message