[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(-) ----------------------------------------------------------------------
