You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/09/28 00:10:51 UTC
[5/5] incubator-beam git commit: [BEAM-604] Use Watermark to Finish
Streaming Job in TestDataflowRunner
[BEAM-604] Use Watermark to Finish Streaming Job in TestDataflowRunner
This closes #916
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/db47c63a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/db47c63a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/db47c63a
Branch: refs/heads/master
Commit: db47c63abe73fce979529ee9e16721eee4d649d7
Parents: 2571cfc 370c171
Author: Luke Cwik <lc...@google.com>
Authored: Tue Sep 27 17:04:27 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Tue Sep 27 17:04:27 2016 -0700
----------------------------------------------------------------------
examples/java/pom.xml | 28 ++
.../beam/examples/WindowedWordCountIT.java | 64 +++++
.../dataflow/testing/TestDataflowRunner.java | 144 +++++++---
.../testing/TestDataflowRunnerTest.java | 287 +++++++++++++++----
.../apache/beam/sdk/testing/StreamingIT.java | 35 +++
5 files changed, 466 insertions(+), 92 deletions(-)
----------------------------------------------------------------------