You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/07/30 22:53:35 UTC
[2/2] beam git commit: This closes #3565: [BEAM-2623] Creates Watch
transform for watching new elements in a family of growing sets
This closes #3565: [BEAM-2623] Creates Watch transform for watching new elements in a family of growing sets
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/95a2eada
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/95a2eada
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/95a2eada
Branch: refs/heads/master
Commit: 95a2eadad1e4f506b9fb9dacf51b4f78b89ef9f6
Parents: 540fa9b 04f2700
Author: Eugene Kirpichov <ki...@google.com>
Authored: Sun Jul 30 15:38:26 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Sun Jul 30 15:38:26 2017 -0700
----------------------------------------------------------------------
...eBoundedSplittableProcessElementInvoker.java | 44 +-
...littableProcessElementsEvaluatorFactory.java | 6 +-
.../org/apache/beam/sdk/transforms/Watch.java | 1009 ++++++++++++++++++
.../apache/beam/sdk/transforms/WatchTest.java | 763 +++++++++++++
4 files changed, 1803 insertions(+), 19 deletions(-)
----------------------------------------------------------------------